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 2021/12/13 10:30:19 UTC
[flink] branch master updated: [FLINK-25153] Inappropriate variable naming (#18003)
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
The following commit(s) were added to refs/heads/master by this push:
new e0b4cbb [FLINK-25153] Inappropriate variable naming (#18003)
e0b4cbb is described below
commit e0b4cbb5694d9c58f871b79e52da250a2f08cd2a
Author: Junfan Zhang <ju...@outlook.com>
AuthorDate: Mon Dec 13 18:29:53 2021 +0800
[FLINK-25153] Inappropriate variable naming (#18003)
---
.../java/org/apache/flink/core/fs/ClosingFSDataOutputStream.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/ClosingFSDataOutputStream.java b/flink-core/src/main/java/org/apache/flink/core/fs/ClosingFSDataOutputStream.java
index b1bf680..69800416 100644
--- a/flink-core/src/main/java/org/apache/flink/core/fs/ClosingFSDataOutputStream.java
+++ b/flink-core/src/main/java/org/apache/flink/core/fs/ClosingFSDataOutputStream.java
@@ -98,9 +98,9 @@ public class ClosingFSDataOutputStream extends FSDataOutputStreamWrapper
FSDataOutputStream delegate, SafetyNetCloseableRegistry registry, String debugInfo)
throws IOException {
- ClosingFSDataOutputStream inputStream =
+ ClosingFSDataOutputStream outputStream =
new ClosingFSDataOutputStream(delegate, registry, debugInfo);
- registry.registerCloseable(inputStream);
- return inputStream;
+ registry.registerCloseable(outputStream);
+ return outputStream;
}
}