You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/03/28 15:24:35 UTC
[6/8] flink git commit: [hotfix] Remove cluttering comments from
JobMaster
[hotfix] Remove cluttering comments from JobMaster
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c67d36a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c67d36a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5c67d36a
Branch: refs/heads/master
Commit: 5c67d36a3a1a2520536737bae1a4a2ff87b0eef2
Parents: fa96c21
Author: Till Rohrmann <tr...@apache.org>
Authored: Wed Mar 28 11:53:56 2018 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Wed Mar 28 17:01:13 2018 +0200
----------------------------------------------------------------------
.../org/apache/flink/runtime/jobmaster/JobMaster.java | 11 +----------
1 file changed, 1 insertion(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/5c67d36a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
index 4313187..d17c97d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
@@ -154,27 +154,20 @@ public class JobMaster extends FencedRpcEndpoint<JobMasterId> implements JobMast
private final ResourceID resourceId;
- /** Logical representation of the job. */
private final JobGraph jobGraph;
private final Time rpcTimeout;
- /** Service to contend for and retrieve the leadership of JM and RM. */
private final HighAvailabilityServices highAvailabilityServices;
- /** Blob server used across jobs. */
private final BlobServer blobServer;
- /** The metrics for the job. */
private final JobManagerJobMetricGroupFactory jobMetricGroupFactory;
- /** The heartbeat manager with task managers. */
private final HeartbeatManager<AccumulatorReport, Void> taskManagerHeartbeatManager;
- /** The heartbeat manager with resource manager. */
private final HeartbeatManager<Void, Void> resourceManagerHeartbeatManager;
- /** The execution context which is used to execute futures. */
private final ScheduledExecutorService scheduledExecutorService;
private final OnCompletionActions jobCompletionActions;
@@ -195,10 +188,9 @@ public class JobMaster extends FencedRpcEndpoint<JobMasterId> implements JobMast
// --------- ResourceManager --------
- /** Leader retriever service used to locate ResourceManager's address. */
private LeaderRetrievalService resourceManagerLeaderRetriever;
- /** Connection with ResourceManager, null if not located address yet or we close it initiative. */
+ @Nullable
private ResourceManagerConnection resourceManagerConnection;
// --------- TaskManagers --------
@@ -207,7 +199,6 @@ public class JobMaster extends FencedRpcEndpoint<JobMasterId> implements JobMast
// -------- Mutable fields ---------
- /** The execution graph of this job. */
private ExecutionGraph executionGraph;
@Nullable