This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 171026917f1365bd69b458e755065400e02275c3 Author: Matthias Pohl <[email protected]> AuthorDate: Fri Apr 1 09:49:27 2022 +0200 [hotfix][runtime] Adds write method for consistency reasons --- .../java/org/apache/flink/core/fs/local/LocalDataOutputStream.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataOutputStream.java b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataOutputStream.java index 1503b4bc2c9..14eaf70c159 100644 --- a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataOutputStream.java +++ b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataOutputStream.java @@ -50,6 +50,11 @@ public class LocalDataOutputStream extends FSDataOutputStream { fos.write(b); } + @Override + public void write(@Nonnull final byte[] b) throws IOException { + fos.write(b); + } + @Override public void write(final byte[] b, final int off, final int len) throws IOException { fos.write(b, off, len);
