flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From canbinzheng <2056268...@qq.com>
Subject [Bug]Question about StreamExecutionEnvironment.createRemoteEnvironment
Date Thu, 30 Mar 2017 12:41:17 GMT
I run two examples in the same client.

first one use       /
ExecutionEnvironment.createRemoteEnvironment("", 59551)/
second one use       
/StreamExecutionEnvironment.createRemoteEnvironment("", 59551)/

the first example run successfully, but the second example failed(connect to
akka timeout), for the second one, if I change host parameter from ip to
hostname, it works.

I check the source code, and I found the ip would be translated into
hostname automatically in the first example, but the second one don't.

I am so confused if the ActorRef must use hostname as part of address, not
ip? is it a bug?

View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Bug-Question-about-StreamExecutionEnvironment-createRemoteEnvironment-tp16854.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.

View raw message