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;
     }
 }