[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/4409ba20 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4409ba20 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4409ba20 Branch: refs/heads/release-1.5 Commit: 4409ba201a54564042dc6690b800b322745942c0 Parents: 557bf0a Author: gyao <[email protected]> Authored: Thu Apr 26 17:44:56 2018 +0200 Committer: Stephan Ewen <[email protected]> Committed: Mon Apr 30 23:25:12 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/4409ba20/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;
