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 2015/03/19 17:52:03 UTC
[2/3] flink git commit: [yarn] Add final modifier to
PollingThread#lock object to make sure immutability.
[yarn] Add final modifier to PollingThread#lock object to make sure immutability.
This closes #494
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6071fb8c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6071fb8c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6071fb8c
Branch: refs/heads/master
Commit: 6071fb8c489874eaff96433930d3b7f67d35dc07
Parents: 0a3ef15
Author: Henry Saputra <he...@gmail.com>
Authored: Tue Mar 17 16:14:44 2015 -0700
Committer: Stephan Ewen <se...@apache.org>
Committed: Thu Mar 19 17:51:04 2015 +0100
----------------------------------------------------------------------
.../src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/6071fb8c/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java b/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
index 8d6b453..804b2e1 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
@@ -402,7 +402,7 @@ public class FlinkYarnCluster extends AbstractFlinkYarnCluster {
private ApplicationId appId;
// ------- status information stored in the polling thread
- private Object lock = new Object();
+ private final Object lock = new Object();
private ApplicationReport lastReport;