This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
from 948f06374d0 [FLINK-26712][table-planner] Metadata keys should not
conflict with physical columns
new 171026917f1 [hotfix][runtime] Adds write method for consistency reasons
new 5fdaf79a31b [hotfix] Fixes typo in NonClosingOutputStreamDecorator
new fafeb7f9534 [FLINK-26957][runtime] Removes flush in
FileSystemJobResultStore
new cb0da8f2817 [FLINK-26957][runtime] Adds invariant to
LocalDataOutputStream to verify that no operation is allowed on a closed stream
The 4 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 +--
...r.java => NonClosingOutputStreamDecorator.java} | 4 +--
7 files changed, 78 insertions(+), 11 deletions(-)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/util/{NonClosingOutpusStreamDecorator.java
=> NonClosingOutputStreamDecorator.java} (90%)
