You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2017/10/09 16:59:08 UTC
[2/9] flink git commit: [hotfix][streaming] Fix typo in parameter and
unify naming in test harnesses
[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 <pi...@gmail.com>
Authored: Thu Aug 24 13:16:14 2017 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
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;
}