[
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 <[email protected]>
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)
