You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/05/24 13:08:04 UTC
[jira] [Commented] (FLINK-6689) Remote StreamExecutionEnvironment
fails to submit jobs against LocalFlinkMiniCluster
[ https://issues.apache.org/jira/browse/FLINK-6689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16022858#comment-16022858 ]
ASF GitHub Bot commented on FLINK-6689:
---------------------------------------
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/3978
[FLINK-6689] fix SIGABRT during GC in the CEP unit tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/NicoK/flink flink-6689
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3978.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3978
----
commit fda6114660434c9d6a7dce4222631e648adc36ea
Author: Nico Kruber <ni...@data-artisans.com>
Date: 2017-05-24T13:00:00Z
[FLINK-6689] fix SIGABRT during GC in the CEP unit tests
----
> 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)