flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "CanBin Zheng (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6224) RemoteStreamEnvironment not resolve hostname of JobManager
Date Fri, 31 Mar 2017 00:54:41 GMT
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("", 59551)
second one use        StreamExecutionEnvironment.createRemoteEnvironment("",

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

View raw message