Nico Kruber created FLINK-6689:
----------------------------------
Summary: Remote StreamExecutionEnvironment fails to submit jobs
against LocalFlinkMiniCluster
Key: FLINK-6689
URL: https://issues.apache.org/jira/browse/FLINK-6689
Project: Flink
Issue Type: Bug
Components: Job-Submission
Affects Versions: 1.3.0
Reporter: Nico Kruber
Fix For: 1.3.0
The following Flink programs fails to execute with the current 1.3 branch (1.2
works):
{code:java}
final String jobManagerAddress = "localhost";
final int jobManagerPort = ConfigConstants.DEFAULT_JOB_MANAGER_IPC_PORT;
final Configuration config = new Configuration();
config.setString(ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY,
jobManagerAddress);
config.setInteger(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY,
jobManagerPort);
config.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true);
final LocalFlinkMiniCluster cluster = new LocalFlinkMiniCluster(config, false);
cluster.start(true);
final StreamExecutionEnvironment env =
StreamExecutionEnvironment.createRemoteEnvironment(jobManagerAddress,
jobManagerPort);
env.fromElements(1l).addSink(new DiscardingSink<Long>());
// fails due to leader session id being wrong:
env.execute("test");
{code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
