CanBin Zheng created FLINK-6224:
-----------------------------------
Summary: RemoteStreamEnvironment not resolve hostname of JobManager
Key: FLINK-6224
URL: https://issues.apache.org/jira/browse/FLINK-6224
Project: Flink
Issue Type: Bug
Components: Client, DataStream API
Affects Versions: 1.2.0
Reporter: CanBin Zheng
Assignee: CanBin Zheng
I run two examples in the same client.
first one use
ExecutionEnvironment.createRemoteEnvironment("10.75.203.170", 59551)
second one use
StreamExecutionEnvironment.createRemoteEnvironment("10.75.203.170", 59551)
the first one runs successfully, but the second example fails(connect to
JobManager timeout), for the second one, if I change host parameter from ip to
hostname, it works.
I checked the source code and found,
ExecutionEnvironment.createRemoteEnvironment
resolves the given hostname, this will lookup the hostname for the given
ip. In contrast, the StreamExecutionEnvironment.createRemoteEnvironment
won't do this.
As Till Rohrmann mentioned, the problem is that with
FLINK-2821 [1], we can no longer resolve the hostname on the JobManager, so,
we'd better resolve hostname for given ip in RemoteStreamEnvironment too.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
