You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2018/04/22 20:40:52 UTC
[16/17] flink git commit: [hotfix] [core] Make some fields final in
LimitedConnectionsFileSystem
[hotfix] [core] Make some fields final in LimitedConnectionsFileSystem
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/29894d06
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/29894d06
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/29894d06
Branch: refs/heads/master
Commit: 29894d06a5b1142650b5c04c44b48acaf2d08c04
Parents: 5380968
Author: Stephan Ewen <se...@apache.org>
Authored: Sun Apr 22 15:12:10 2018 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Sun Apr 22 16:28:35 2018 +0200
----------------------------------------------------------------------
.../org/apache/flink/core/fs/LimitedConnectionsFileSystem.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/29894d06/flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java b/flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java
index fdf54e0..40e101c 100644
--- a/flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java
+++ b/flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java
@@ -717,7 +717,7 @@ public class LimitedConnectionsFileSystem extends FileSystem {
private volatile StreamTimeoutException timeoutException;
/** Flag tracking whether the stream was already closed, for proper inactivity tracking. */
- private AtomicBoolean closed = new AtomicBoolean();
+ private final AtomicBoolean closed = new AtomicBoolean();
OutStream(FSDataOutputStream originalStream, LimitedConnectionsFileSystem fs) {
this.originalStream = checkNotNull(originalStream);
@@ -843,7 +843,7 @@ public class LimitedConnectionsFileSystem extends FileSystem {
private final StreamProgressTracker progressTracker;
/** Flag tracking whether the stream was already closed, for proper inactivity tracking. */
- private AtomicBoolean closed = new AtomicBoolean();
+ private final AtomicBoolean closed = new AtomicBoolean();
InStream(FSDataInputStream originalStream, LimitedConnectionsFileSystem fs) {
this.originalStream = checkNotNull(originalStream);