|
|
|
FLINK-26331
|
FLINK-11813
Make max retries configurable
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-26296
|
FLINK-11813
Add missing documentation
|
Mika Naylor
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-26117
|
FLINK-11813
JobManagerMetricGroup needs to implement GloballyCleanableResource as well
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-26017
|
FLINK-11813
Add debug log message when marking a job result as dirty
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-26015
|
FLINK-11813
FileSystemJobResultStore fails to access Minio
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-25985
|
FLINK-11813
e2e test covering the main functionality of the JobResultStore
|
Unassigned
|
Matthias Pohl
|
|
Resolved |
Duplicate
|
|
|
|
|
|
|
|
FLINK-25978
|
FLINK-11813
DispatcherTest.testJobDataAreCleanedUpInCorrectOrderOn*Job can be removed
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-25974
|
FLINK-11813
Make cancellation of jobs depend on the JobResultStore
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-25973
|
FLINK-11813
Rename ArchivedExecutionGraph.createFromInitializingJob into more generic createSparseArchivedExecutionGraph
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-25955
|
FLINK-11813
Add JobManagerRunner implementation that picks up dirty job results to be cleaned up
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-25954
|
FLINK-11813
Add cleanup tests to BlobServerCleanupTest
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-25953
|
FLINK-11813
Reorganizes tests around Dispatcher cleanup
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-25433
|
FLINK-11813
Integrate retry strategy for cleanup stage
|
Matthias Pohl
|
Matthias Pohl
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-25432
|
FLINK-11813
Introduce common interfaces for cleaning up local and global job data
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-25431
|
FLINK-11813
Implement file-based JobResultStore
|
Mika Naylor
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-25430
|
FLINK-11813
Introduce JobResultStore
|
Matthias Pohl
|
Matthias Pohl
|
|
Resolved |
Fixed
|
|
|
|
|