dawidwys commented on a change in pull request #13944:
URL: https://github.com/apache/flink/pull/13944#discussion_r518663700
##########
File path:
flink-tests/src/test/java/org/apache/flink/api/datastream/DataStreamBatchExecutionITCase.java
##########
@@ -127,17 +130,17 @@ public void batchSumSingleResultPerKey() throws Exception
{
}
private StreamExecutionEnvironment getExecutionEnvironment() {
- final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
Configuration config = new Configuration();
config.set(ExecutionOptions.RUNTIME_MODE,
RuntimeExecutionMode.BATCH);
- env.configure(config,
DataStreamBatchExecutionITCase.class.getClassLoader());
+ config.set(CoreOptions.DEFAULT_PARALLELISM, 1);
Review comment:
Not necessarily. It is more to verify that we can pass parallelism that
way as well. I can revert.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
