This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 741aa43e2c72dc93762ad8ab0ee6781bda181f05 Author: Piotr Nowojski <[email protected]> AuthorDate: Thu Aug 16 17:49:01 2018 +0200 [hotfix][tests] Deduplicate code in AbstractStreamOperatorTestHarness constructor --- .../streaming/util/AbstractStreamOperatorTestHarness.java | 13 +++---------- 1 file changed, 3 insertions(+), 10 deletions(-) diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java index 8ee8c03..0e120eb 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java @@ -139,16 +139,9 @@ public class AbstractStreamOperatorTestHarness<OUT> implements AutoCloseable { int subtaskIndex) throws Exception { this( operator, - new MockEnvironmentBuilder() - .setTaskName("MockTask") - .setMemorySize(3 * 1024 * 1024) - .setInputSplitProvider(new MockInputSplitProvider()) - .setBufferSize(1024) - .setMaxParallelism(maxParallelism) - .setParallelism(parallelism) - .setSubtaskIndex(subtaskIndex) - .build(), - true, + maxParallelism, + parallelism, + subtaskIndex, new OperatorID()); }
