[ https://issues.apache.org/jira/browse/FLINK-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929719#comment-15929719 ]
ASF GitHub Bot commented on FLINK-6058: --------------------------------------- GitHub user fanyon opened a pull request: https://github.com/apache/flink/pull/3561 [FLINK-6058] fix read DEFAULT_PARALLELISM from ContextEnvironment fix read DEFAULT_PARALLELISM from ContextEnvironment You can merge this pull request into a Git repository by running: $ git pull https://github.com/fanyon/flink FLINK-6058 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/3561.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 #3561 ---- commit 446cec49e1aa75c4258c07994d0c5ae18ea0c128 Author: mengji.fy <mengji...@taobao.com> Date: 2017-03-17T10:33:34Z [FLINK-6058] fix read DEFAULT_PARALLELISM from ContextEnvironment ---- > Don't read DEFAULT_PARALLELISM from GlobalConfiguration > ------------------------------------------------------- > > Key: FLINK-6058 > URL: https://issues.apache.org/jira/browse/FLINK-6058 > Project: Flink > Issue Type: Improvement > Components: DataStream API > Reporter: Aljoscha Krettek > Priority: Blocker > Fix For: 1.3.0 > > > In the constructor of {{StreamContextEnvironment}} we read the > {{DEFAULT_PARALLELISM}} from the {{GlobalConfiguration}}. This assumes that > the environment variables are correctly set and can lead to problems. We > should read the default parallelism in the client and set it in the > {{ContextEnvironment}} that it creates. This can then be read by the > {{StreamContextEnvironment}}. -- This message was sent by Atlassian JIRA (v6.3.15#6346)