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/30 21:23:09 UTC
[08/15] flink git commit: [hotfix] [yarn] Remove unused field
appReport in YarnClusterClient.
[hotfix] [yarn] Remove unused field appReport in YarnClusterClient.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/02a9d3d8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/02a9d3d8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/02a9d3d8
Branch: refs/heads/master
Commit: 02a9d3d878098ab25c4989680b07aa11ce96c859
Parents: 17c68e5
Author: gyao <ga...@data-artisans.com>
Authored: Thu Apr 26 17:44:56 2018 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Apr 30 21:21:00 2018 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/flink/yarn/YarnClusterClient.java | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/02a9d3d8/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java
index 2ac9664..3edd6e4 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java
@@ -68,7 +68,6 @@ public class YarnClusterClient extends ClusterClient<ApplicationId> {
private final int slotsPerTaskManager;
private final LazApplicationClientLoader applicationClient;
private final FiniteDuration akkaDuration;
- private final ApplicationReport appReport;
private final ApplicationId appId;
private final String trackingURL;
@@ -101,7 +100,6 @@ public class YarnClusterClient extends ClusterClient<ApplicationId> {
this.clusterDescriptor = clusterDescriptor;
this.numberTaskManagers = numberTaskManagers;
this.slotsPerTaskManager = slotsPerTaskManager;
- this.appReport = appReport;
this.appId = appReport.getApplicationId();
this.trackingURL = appReport.getTrackingUrl();
this.newlyCreatedCluster = newlyCreatedCluster;