[jira] [Created] (FLINK-6689) Remote StreamExecutionEnvironment fails to submit jobs against LocalFlinkMiniCluster

[Shang Yuanchun (Jira)]

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)