issues
search
flink-extended
/
flink-remote-shuffle
Remote Shuffle Service for Flink
Apache License 2.0
191
stars
56
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Conflict with Flink 1.15.4
#94
dangshazi
opened
1 year ago
2
`SortBuffer` is blocked at `requestBufferFromPool`
#93
KevinLeeDan
opened
1 year ago
2
flink 1.15.3 compile failed
#92
winnerhero
opened
1 year ago
0
[FRS-89] Fix incompatibility with the new version of Flink
#90
TanYuxin-tyx
closed
1 year ago
0
Incompatibility with the new version of Flink
#89
TanYuxin-tyx
closed
1 year ago
0
[FRS-76] Use apiextensions v1 instead of v1beta1 for remote shuffle operator crd
#88
wsry
closed
2 years ago
0
flink 1.15.2 compile failed
#87
licc
closed
2 years ago
1
Multi-tenant throttling and guarantee
#86
dangshazi
opened
2 years ago
0
Add JVM CPU usage metirc
#85
dangshazi
opened
2 years ago
0
[FRS-77] Fix ShuffleReadClient block when create channel
#84
dangshazi
closed
2 years ago
1
Adapt to Flink 1.16
#83
TanYuxin-tyx
closed
1 year ago
1
[FRS-81] Introduce new compression algorithms with higher compression ratio
#82
TanYuxin-tyx
closed
2 years ago
0
Introduce new compression algorithms with higher compression ratio
#81
TanYuxin-tyx
closed
2 years ago
0
[FRS-79] Fix the bug that BaseMapPartition may not read data sequentially
#80
TanYuxin-tyx
closed
2 years ago
1
Fix the bug that BaseMapPartition may not read data sequentially
#79
TanYuxin-tyx
closed
2 years ago
0
Further improvements umbrella for remote shuffle service
#78
TanYuxin-tyx
closed
1 year ago
0
ShuffleReadClient is blocked when create channel
#77
dangshazi
closed
2 years ago
2
Use apiextensions v1 instead of v1beta1 for remote shuffle operator crd
#76
wsry
closed
2 years ago
0
Explicitly exit ShuffleWorker process when terminate future finished
#75
Aitozi
opened
2 years ago
1
[FRS-66] Introduce shuffleworker deployed by statefulset and pvc
#74
Aitozi
opened
2 years ago
1
[FRS-72] Fix the heartbeat issue caused by zookeeper restart
#73
wsry
closed
2 years ago
0
Fix the possible heartbeat issue caused by Zookeeper restart
#72
wsry
closed
2 years ago
0
Add more information about the ShuffleWorker in the ShuffleManagerClient
#71
Aitozi
opened
2 years ago
0
[FRS-69] Add the metrics reporter configuration in documents and modify the delimiter of the metric reporter classes
#70
TanYuxin-tyx
closed
2 years ago
2
Add the metrics reporter configuration in documents and modify the delimiter of the metric reporter classes
#69
TanYuxin-tyx
closed
2 years ago
0
[FRS-65] Support to limit the maximum storage space can be used per disk
#68
wsry
closed
2 years ago
1
[hotfix] Add fast profile to skip check
#67
Aitozi
closed
2 years ago
2
Support to use StatefulSet + Pvc to deploy the shuffle service
#66
Aitozi
opened
2 years ago
2
Support to restrict the maximum storage space can be used per disk
#65
wsry
closed
2 years ago
0
[FRS-16]Support reporting metrics to prometheus
#64
dangshazi
closed
2 years ago
5
[FRS-62] Fix metric: reading throngh
#63
dangshazi
closed
2 years ago
1
Metric ReadingThroughput missed
#62
dangshazi
closed
2 years ago
1
[FRS-59] Fix SHUFFLE_CONF_DIR didn't work in standalone mode
#61
dangshazi
closed
2 years ago
4
Avoid specifying "remote-shuffle.manager.rpc-address" when start ShuffleManager in standalone mode
#60
dangshazi
opened
2 years ago
1
SHUFFLE_CONF_DIR didn't work in standalone mode
#59
dangshazi
closed
2 years ago
2
[FRS-13] Implement ReducePartition for remote shuffle service
#58
TanYuxin-tyx
closed
1 year ago
0
[FRS-31] Upgrade log4j version to 2.17.2
#57
wsry
closed
2 years ago
0
[FRS-55] Ensure all resources will be released for result partition and input gate when closed
#56
wsry
closed
2 years ago
0
Ensure all resources will be released for result partition and input gate when closed
#55
wsry
closed
2 years ago
0
[FRS-53] Not trigger fatal error if Flink job has finished when notifying new shuffle manager address
#54
wsry
closed
2 years ago
0
Not trigger fatal error if Flink job has finished when notifying new shuffle manager address
#53
wsry
closed
2 years ago
0
Support Kubernetes HA Services
#52
czy006
opened
2 years ago
1
[FRS-50] Enable reading buffer floating for better fairness
#51
wsry
closed
2 years ago
0
Enable reading buffer floating for better fairness
#50
wsry
closed
2 years ago
0
[FRS-36] Support to config the shuffle cluster name prefix to use at Flink side
#49
wsry
closed
2 years ago
0
[FRS-47] Job can switch to new shuffle cluster only when the old cluster is unavailable
#48
wsry
closed
2 years ago
2
Job can switch to new shuffle cluster only when the old cluster is unavailable
#47
wsry
closed
2 years ago
0
data request should implement crc check strategy
#46
lichaojacobs
closed
2 years ago
4
[FRS-13] Draft pr for implementing reduce partition.
#45
TanYuxin-tyx
closed
2 years ago
1
[FRS-15] Add more metrics
#44
wsry
closed
2 years ago
0
Next