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/23 04:45:05 UTC
[13/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/bc54ee9d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bc54ee9d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/bc54ee9d
Branch: refs/heads/release-1.5
Commit: bc54ee9da90f61e7b9a2f95d4aad3c4a3f86e432
Parents: 814d9ea
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 22:42:39 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/bc54ee9d/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);