Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5312#discussion_r163227450
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -596,11 +596,11 @@ public int run(String[] args) throws
CliArgsException, FlinkException {
//------------------ ClusterClient
deployed, handle connection details
yarnApplicationId =
clusterClient.getClusterId();
- String jobManagerAddress =
-
clusterClient.getJobManagerAddress().getAddress().getHostName() +
- ':' +
clusterClient.getJobManagerAddress().getPort();
+// String jobManagerAddress =
+//
clusterClient.getJobManagerAddress().getAddress().getHostName() +
--- End diff --
had to add it back because `YARNSessionCapacitySchedulerITCase` is relying
on it
---
