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:25:47 UTC
[3/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/a2c8655c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a2c8655c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a2c8655c
Branch: refs/heads/release-1.5
Commit: a2c8655cb9623709d65c9e686c1823335516eda3
Parents: eae610d
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:25:17 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/a2c8655c/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