[ https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14741325#comment-14741325 ]
ASF GitHub Bot commented on FLINK-2373: --------------------------------------- Github user akunft commented on the pull request: https://github.com/apache/flink/pull/1066#issuecomment-139622654 * rebased * replaced collection output with ```collect()``` in RemoteEnvironmentITCase and ExecutionEnvironmentITCase * added ```createRemoteEnvironment``` method with config parameter in Scala ExecutionEnvironment > Add configuration parameter to createRemoteEnvironment method > ------------------------------------------------------------- > > Key: FLINK-2373 > URL: https://issues.apache.org/jira/browse/FLINK-2373 > Project: Flink > Issue Type: Bug > Components: other > Reporter: Andreas Kunft > Priority: Minor > Original Estimate: 24h > Remaining Estimate: 24h > > Currently there is no way to provide a custom configuration upon creation of > a remote environment (via ExecutionEnvironment.createRemoteEnvironment(...)). > This leads to errors when the submitted job exceeds the default value for the > max. payload size in Akka, as we can not increase the configuration value > (akka.remote.OversizedPayloadException: Discarding oversized payload...) > Providing an overloaded method with a configuration parameter for the remote > environment fixes that. -- This message was sent by Atlassian JIRA (v6.3.4#6332)