issues
search
apache
/
celeborn
Apache Celeborn is an elastic and high-performance service for shuffle and spilled data.
https://celeborn.apache.org/
Apache License 2.0
886
stars
359
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
[CELEBORN-1689] optimize Master AppHeartbeat/RequestSlots RPC performance
#2889
xy2953396112
closed
1 hour ago
0
[CELEBORN-1697] Improve ThreadStackTrace for thread dump
#2888
SteNicholas
opened
1 hour ago
0
[CELEBORN-1696] StorageManager#cleanFile should remove file info
#2887
reswqa
opened
8 hours ago
0
[CELEBORN-1693] Fix storageFetcherPool concurrent problem
#2886
reswqa
opened
10 hours ago
2
[CELEBORN-1692] Set mount point in fromPbFileInfoMap
#2885
reswqa
opened
11 hours ago
0
[CELEBORN-1691] Fix the issue that upstream tasks don't rerun and the current task still retry when failed to decompress in flink
#2884
reswqa
opened
11 hours ago
0
[MINOR] Remove unused TODO comments in CelebornTierProducerAgent#processBuffer
#2883
reswqa
opened
11 hours ago
0
CELEBORN-1689: CLI Support for Ratis APIs
#2882
akpatnam25
opened
13 hours ago
3
[CELEBORN-1641]Pack the output spark client jar with the major.minor version
#2881
zaynt4606
opened
20 hours ago
0
[CELEBORN-1190][FOLLOWUP] Fix WARNING of error prone
#2880
SteNicholas
opened
1 day ago
1
[CELEBORN-1687] Highlight flink session cluster issue in doc
#2879
reswqa
closed
10 hours ago
0
[CELEBORN-1686] Avoid return the same pushTaskQueue
#2878
cxzl25
opened
1 day ago
0
[CELEBORN-1684] Fix ambiguous client jar expression of document
#2877
zaynt4606
closed
1 day ago
4
[CELEBORN-1683] Support to check worker versions
#2876
turboFei
opened
1 day ago
5
[CELEBORN-1678][FOLLOWUP] Improve Celeborn CLI user guide
#2875
SteNicholas
closed
1 day ago
1
[CELEBORN-1682] Add java tools.jar into classpath for JVM quake
#2874
turboFei
closed
2 days ago
0
[CELEBORN-1490][CIP-6] Support process large buffer in flink hybrid shuffle
#2873
reswqa
closed
2 days ago
1
[CELEBORN-1564][FOLLOWUP] Remove unused variables
#2872
turboFei
closed
5 days ago
0
[CELEBORN-1531][FOLLOWUP] Assign the scheduled check task
#2871
turboFei
closed
1 day ago
1
[CELEBORN-1660] Using map for workers to find worker fast
#2870
turboFei
closed
5 days ago
1
Revert worker info pool
#2869
turboFei
closed
5 days ago
0
[CELEBORN-1636][FOLLOWUP] Add Factor and get available workers from requestSlots RPC
#2868
zaynt4606
closed
5 days ago
0
[CELEBORN-1490][CIP-6] Add Flink hybrid shuffle doc
#2867
reswqa
closed
5 days ago
0
[CELEBORN-1680] Introduce ShuffleFallbackCount metrics
#2866
turboFei
opened
6 days ago
1
[CELEBORN-1679] Estimated ApplicationDiskUsage in cluster should be multiplied by worker count.
#2865
Z1Wu
opened
6 days ago
4
[CELEBORN-1678] Add Celeborn CLI User guide in README
#2862
akpatnam25
closed
1 week ago
3
[CELEBORN-1477][FOLLOWUP] Remove scala binary version from openapi-client artifactId
#2861
turboFei
closed
5 days ago
1
[FEATURE] Support web ui
#2860
melin
closed
5 days ago
1
[CELEBORN-1490][CIP-6] Add Flink Hybrid Shuffle IT test cases
#2859
reswqa
closed
5 days ago
1
[CELEBORN-1677][BUILD] Update SCM information for SBT build configuration
#2858
cfmcgrady
closed
1 week ago
1
[CELEBORN-1675] User with zero quota should not be allowed to submit any shuffle to cluster.
#2857
Z1Wu
opened
1 week ago
3
[CELEBORN-1636][FOLLOWUP] Cache available workers in Master
#2856
zaynt4606
closed
5 hours ago
2
[CELEBORN-1673] Support retry create client
#2855
RexXiong
closed
6 days ago
1
[CELEBORN-1671] CelebornShuffleReader will try replica if create client failed
#2854
FMX
closed
10 hours ago
0
[CELEBORN-1674] Fix reader thread name of MapPartitionData
#2853
SteNicholas
closed
1 week ago
0
[CELEBORN-1636][FOLLOWUP] Dynamic resources will only be utilized in case of candidates shortages
#2852
zaynt4606
closed
1 day ago
2
[CELEBORN-1672] Bump Spark from 3.4.3 to 3.4.4
#2851
SteNicholas
closed
5 days ago
0
[CELEBORN-1642][CIP-11] Support multiple worker tags
#2850
s0nskar
closed
1 week ago
1
[CELEBORN-1670] Avoid swallowing InterruptedException in ShuffleClientImpl
#2849
jiang13021
opened
1 week ago
1
[CELEBORN-1516][FOLLOWUP] Support reset method for DynamicConfigServiceFactory
#2848
s0nskar
closed
1 week ago
5
[CELEBORN-1669] Fix NullPointerException for PartitionFilesSorter#updateSortedShuffleFiles after cleaning up expired shuffle key
#2847
SteNicholas
closed
1 week ago
0
[CELEBORN-1668] Fix NPE when handle closed file writers
#2846
FMX
closed
1 week ago
0
[CELEBORN-1664][0.5] Fix secret fetch failures after LEADER master failover
#2845
YutingWang98
closed
1 week ago
2
[CELEBORN-1619][CIP-11] Integrate tags manager with config service
#2844
s0nskar
opened
2 weeks ago
1
[CELEBORN-1667] Fix NPE & LEAK occurring prior to worker registration
#2843
zhaostu4
closed
1 week ago
3
[CELEBORN-1666] Bump scala-protoc from 1.0.6 to 1.0.7
#2842
cfmcgrady
closed
1 week ago
1
[MINOR] Fix typo in ExceptionUtils
#2841
jiang13021
closed
2 weeks ago
0
[CELEBORN-1665][0.5] CommitHandler should process CommitFilesResponse with COMMIT_FILE_EXCEPTION status
#2840
SteNicholas
closed
2 weeks ago
0
[CELEBORN-1660] Using map for workers to find worker fast and WokerInfo pool to reuse objects
#2839
turboFei
closed
5 days ago
8
[CELEBORN-1665] CommitHandler should process CommitFilesResponse with COMMIT_FILE_EXCEPTION status
#2838
SteNicholas
closed
2 weeks ago
1
Next