|
|
|
FLINK-6640
|
FLINK-6537
Ensure registration of shared state happens before externalizing a checkpoint
|
Stefan Richter
|
Stefan Richter
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-6633
|
FLINK-6537
Register with shared state registry before adding to CompletedCheckpointStore
|
Stefan Richter
|
Stefan Richter
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-6599
|
FLINK-6537
Communicate last committed checkpoint through trigger checkpoint message
|
Unassigned
|
Stefan Richter
|
|
Closed |
Abandoned
|
|
|
|
|
|
|
|
FLINK-6545
|
FLINK-6537
Make incremental checkpoints externalizable
|
Unassigned
|
Stefan Richter
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-6540
|
FLINK-6537
Add more thorough tests for RocksDB and incremental checkpointing
|
Unassigned
|
Stefan Richter
|
|
Closed |
Abandoned
|
|
|
|
|
|
|
|
FLINK-6535
|
FLINK-6537
JobID should not be part of the registration key to the SharedStateRegistry
|
Stefan Richter
|
Stefan Richter
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-6534
|
FLINK-6537
SharedStateRegistry is disposing state handles from main thread
|
Stefan Richter
|
Stefan Richter
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-6533
|
FLINK-6537
Duplicated registration of new shared state when checkpoint confirmations are still pending
|
Stefan Richter
|
Stefan Richter
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-6527
|
FLINK-6537
OperatorSubtaskState has empty implementations of (un)/registerSharedStates
|
Stefan Richter
|
Stefan Richter
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-6505
|
FLINK-6537
Proactively cleanup local FS for RocksDBKeyedStateBackend on startup
|
Bowen Li
|
Stefan Richter
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-6504
|
FLINK-6537
Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend
|
Xiaogang Shi
|
Stefan Richter
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-6475
|
FLINK-6537
Incremental snapshots in RocksDB hold lock during async file upload
|
Stefan Richter
|
Stefan Richter
|
|
Closed |
Fixed
|
|
|
|
|