This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3f8a4c8 [hotfix][yarn] Disable Yarn Debug logging for tests add 4050cf3 [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has completed writing No new revisions were added by this update. Summary of changes: .../local/LocalRecoverableFsDataOutputStream.java | 4 +- .../core/fs/local/LocalRecoverableWriter.java | 2 +- .../filesystem/FSDataOutputStreamWrapper.java | 64 ++++++ .../FsCheckpointMetadataOutputStream.java | 46 ++-- .../filesystem/MetadataOutputStreamWrapper.java | 78 +++++++ .../state/filesystem/RecoverableStreamWrapper.java | 40 ++-- .../CheckpointStateOutputStreamTest.java | 36 ++- .../FsCheckpointMetadataOutputStreamTest.java | 243 +++++++++++++++++++++ .../flink/test/checkpointing/SavepointITCase.java | 7 + 9 files changed, 475 insertions(+), 45 deletions(-) create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FSDataOutputStreamWrapper.java create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/MetadataOutputStreamWrapper.java copy flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/utils/NoOpRecoverableFsDataOutputStream.java => flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/RecoverableStreamWrapper.java (53%) create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStreamTest.java