TisonKun commented on a change in pull request #9575: [FLINK-13912][client]
Remove ClusterClient#getClusterConnectionInfo
URL: https://github.com/apache/flink/pull/9575#discussion_r319634038
##########
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
##########
@@ -513,12 +509,8 @@ private void
validateClusterSpecification(ClusterSpecification clusterSpecificat
yarnApplication,
validClusterSpecification);
- String host = report.getHost();
- int port = report.getRpcPort();
-
- // Correctly initialize the Flink config
- flinkConfiguration.setString(JobManagerOptions.ADDRESS, host);
- flinkConfiguration.setInteger(JobManagerOptions.PORT, port);
Review comment:
Aha! Even I found a reason that we "need" these stmts because when build
HAService at client-side we have to build one just like on cluster client thus
if `JobManagerOption` not set it will fail with
```
org.apache.flink.client.deployment.ClusterDeploymentException: Could not
deploy Yarn job cluster.
at
org.apache.flink.yarn.YARNITCase.lambda$testPerJobMode$0(YARNITCase.java:109)
at org.apache.flink.yarn.YARNITCase.testPerJobMode(YARNITCase.java:69)
Caused by: org.apache.flink.util.ConfigurationException: Config parameter
'Key: 'jobmanager.rpc.address' , default: null (fallback keys: [])' is missing
(hostname/address of JobManager to connect to).
at
org.apache.flink.yarn.YARNITCase.lambda$testPerJobMode$0(YARNITCase.java:109)
at org.apache.flink.yarn.YARNITCase.testPerJobMode(YARNITCase.java:69)
```
this is what FLINK-13750 want to resolve, i.e., do not instance service that
is never needed.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
