You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/04/04 12:32:16 UTC
[flink] 02/05: [hotfix] Fixes typo in NonClosingOutputStreamDecorator
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 116f297478f2d443178510565b1cd5a2f387e241
Author: Matthias Pohl <ma...@ververica.com>
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);
}