You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ga...@apache.org on 2022/01/24 13:47:43 UTC

[flink] branch master updated (3f8a4c8 -> 4050cf3)

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