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 5fdaf79a31bb1eccdd3cac4b1b8b52e585e89b0e Author: Matthias Pohl <[email protected]> AuthorDate: Fri Apr 1 18:09:45 2022 +0200 [hotfix] Fixes typo in NonClosingOutputStreamDecorator --- .../flink/runtime/state/SnappyStreamCompressionDecorator.java | 4 ++-- .../org/apache/flink/runtime/state/StreamCompressionDecorator.java | 6 +++--- .../flink/runtime/state/UncompressedStreamCompressionDecorator.java | 4 ++-- ...pusStreamDecorator.java => NonClosingOutputStreamDecorator.java} | 4 ++-- 4 files changed, 9 insertions(+), 9 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/SnappyStreamCompressionDecorator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/SnappyStreamCompressionDecorator.java index 5b024149d1f..ff3318b55cb 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/SnappyStreamCompressionDecorator.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/SnappyStreamCompressionDecorator.java @@ -20,7 +20,7 @@ package org.apache.flink.runtime.state; import org.apache.flink.annotation.Internal; import org.apache.flink.runtime.util.NonClosingInputStreamDecorator; -import org.apache.flink.runtime.util.NonClosingOutpusStreamDecorator; +import org.apache.flink.runtime.util.NonClosingOutputStreamDecorator; import org.xerial.snappy.SnappyFramedInputStream; import org.xerial.snappy.SnappyFramedOutputStream; @@ -42,7 +42,7 @@ public class SnappyStreamCompressionDecorator extends StreamCompressionDecorator private static final double MIN_COMPRESSION_RATIO = 0.85d; @Override - protected OutputStream decorateWithCompression(NonClosingOutpusStreamDecorator stream) + protected OutputStream decorateWithCompression(NonClosingOutputStreamDecorator stream) throws IOException { return new SnappyFramedOutputStream(stream, COMPRESSION_BLOCK_SIZE, MIN_COMPRESSION_RATIO); } diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/StreamCompressionDecorator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/StreamCompressionDecorator.java index ad9e52c64e2..e32a51b97bb 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/StreamCompressionDecorator.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/StreamCompressionDecorator.java @@ -20,7 +20,7 @@ package org.apache.flink.runtime.state; import org.apache.flink.annotation.Internal; import org.apache.flink.runtime.util.NonClosingInputStreamDecorator; -import org.apache.flink.runtime.util.NonClosingOutpusStreamDecorator; +import org.apache.flink.runtime.util.NonClosingOutputStreamDecorator; import java.io.IOException; import java.io.InputStream; @@ -46,7 +46,7 @@ public abstract class StreamCompressionDecorator implements Serializable { * @return an output stream that is decorated by the compression scheme. */ public final OutputStream decorateWithCompression(OutputStream stream) throws IOException { - return decorateWithCompression(new NonClosingOutpusStreamDecorator(stream)); + return decorateWithCompression(new NonClosingOutputStreamDecorator(stream)); } /** @@ -64,7 +64,7 @@ public abstract class StreamCompressionDecorator implements Serializable { * @param stream the stream to decorate * @return an output stream that is decorated by the compression scheme. */ - protected abstract OutputStream decorateWithCompression(NonClosingOutpusStreamDecorator stream) + protected abstract OutputStream decorateWithCompression(NonClosingOutputStreamDecorator stream) throws IOException; /** diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/UncompressedStreamCompressionDecorator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/UncompressedStreamCompressionDecorator.java index 05ac250ea38..7fa053e069b 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/UncompressedStreamCompressionDecorator.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/UncompressedStreamCompressionDecorator.java @@ -20,7 +20,7 @@ package org.apache.flink.runtime.state; import org.apache.flink.annotation.Internal; import org.apache.flink.runtime.util.NonClosingInputStreamDecorator; -import org.apache.flink.runtime.util.NonClosingOutpusStreamDecorator; +import org.apache.flink.runtime.util.NonClosingOutputStreamDecorator; import java.io.IOException; import java.io.InputStream; @@ -36,7 +36,7 @@ public class UncompressedStreamCompressionDecorator extends StreamCompressionDec private static final long serialVersionUID = 1L; @Override - protected OutputStream decorateWithCompression(NonClosingOutpusStreamDecorator stream) + protected OutputStream decorateWithCompression(NonClosingOutputStreamDecorator stream) throws IOException { return stream; } diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/util/NonClosingOutpusStreamDecorator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/util/NonClosingOutputStreamDecorator.java similarity index 90% rename from flink-runtime/src/main/java/org/apache/flink/runtime/util/NonClosingOutpusStreamDecorator.java rename to flink-runtime/src/main/java/org/apache/flink/runtime/util/NonClosingOutputStreamDecorator.java index dee7d7d0057..c4057737525 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/util/NonClosingOutpusStreamDecorator.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/util/NonClosingOutputStreamDecorator.java @@ -25,9 +25,9 @@ import java.io.OutputStream; /** Decorator for input streams that ignores calls to {@link OutputStream#close()}. */ @Internal -public class NonClosingOutpusStreamDecorator extends ForwardingOutputStream { +public class NonClosingOutputStreamDecorator extends ForwardingOutputStream { - public NonClosingOutpusStreamDecorator(OutputStream delegate) { + public NonClosingOutputStreamDecorator(OutputStream delegate) { super(delegate); }
