jiexray commented on pull request #8751: URL: https://github.com/apache/flink/pull/8751#issuecomment-796651664
https://github.com/klion26/flink/blob/2dda201498d913b3fbf2e7d078dd5440652e6a19/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java#L191 Hello, the FSDataOutputStream for a checkpoint is closed, when the checkpoint is notified from JM. Why do you delay the close of the output stream. It can be closed when the RocksStateUploader finishes uploading all sst files for the current checkpoint. Since the output stream has already been unuseful, keeping it open is a waste. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
