This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from e031f82528b [hotfix] Modify spelling error in IOUtils.java
new 74ecbd13cf8 [hotfix][runtime] Adds write method for consistency reasons
new 116f297478f [hotfix] Fixes typo in NonClosingOutputStreamDecorator
new 098dc7eca31 [hotfix] Fixes error in JavaDoc
new c50b0706237 [FLINK-26957][runtime] Removes flush in
FileSystemJobResultStore
new caa296b813b [FLINK-26957][runtime] Adds invariant to
LocalDataOutputStream to verify that no operation is allowed on a closed stream
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/core/fs/local/LocalDataOutputStream.java | 23 +++++++++++++
.../flink/core/fs/local/LocalFileSystemTest.java | 40 ++++++++++++++++++++++
.../highavailability/FileSystemJobResultStore.java | 8 +++--
.../state/SnappyStreamCompressionDecorator.java | 4 +--
.../runtime/state/StreamCompressionDecorator.java | 6 ++--
.../UncompressedStreamCompressionDecorator.java | 4 +--
.../flink/runtime/util/ForwardingOutputStream.java | 4 +--
...r.java => NonClosingOutputStreamDecorator.java} | 4 +--
8 files changed, 80 insertions(+), 13 deletions(-)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/util/{NonClosingOutpusStreamDecorator.java
=> NonClosingOutputStreamDecorator.java} (90%)
