[hotfix][streaming] Fix typo in parameter and unify naming in test harnesses
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/867c0124 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/867c0124 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/867c0124 Branch: refs/heads/master Commit: 867c0124e2959ea3c90dab13cc12ba43c2eb0f64 Parents: 2f651e9 Author: Piotr Nowojski <[email protected]> Authored: Thu Aug 24 13:16:14 2017 +0200 Committer: Aljoscha Krettek <[email protected]> Committed: Mon Oct 9 18:58:36 2017 +0200 ---------------------------------------------------------------------- .../flink/streaming/util/AbstractStreamOperatorTestHarness.java | 4 ++-- .../flink/streaming/util/OneInputStreamOperatorTestHarness.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/867c0124/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java ---------------------------------------------------------------------- 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 793e8f6..3d1b6fd 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 @@ -120,7 +120,7 @@ public class AbstractStreamOperatorTestHarness<OUT> implements AutoCloseable { public AbstractStreamOperatorTestHarness( StreamOperator<OUT> operator, int maxParallelism, - int numSubtasks, + int parallelism, int subtaskIndex) throws Exception { this( @@ -133,7 +133,7 @@ public class AbstractStreamOperatorTestHarness<OUT> implements AutoCloseable { new Configuration(), new ExecutionConfig(), maxParallelism, - numSubtasks, + parallelism, subtaskIndex)); } http://git-wip-us.apache.org/repos/asf/flink/blob/867c0124/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/OneInputStreamOperatorTestHarness.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/OneInputStreamOperatorTestHarness.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/OneInputStreamOperatorTestHarness.java index 8a0996f..c8fa2a4 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/OneInputStreamOperatorTestHarness.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/OneInputStreamOperatorTestHarness.java @@ -65,9 +65,9 @@ public class OneInputStreamOperatorTestHarness<IN, OUT> public OneInputStreamOperatorTestHarness( OneInputStreamOperator<IN, OUT> operator, int maxParallelism, - int numTubtasks, + int parallelism, int subtaskIndex) throws Exception { - super(operator, maxParallelism, numTubtasks, subtaskIndex); + super(operator, maxParallelism, parallelism, subtaskIndex); this.oneInputOperator = operator; }
