You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/01/16 12:27:15 UTC
[flink] branch master updated: [hotfix] Fix parameter name
KeyedCoProcessOperator constructor
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 9a21cc0 [hotfix] Fix parameter name KeyedCoProcessOperator constructor
9a21cc0 is described below
commit 9a21cc0b216da5198854ae52add53ffad3af4e60
Author: leesf <49...@qq.com>
AuthorDate: Wed Jan 16 20:27:08 2019 +0800
[hotfix] Fix parameter name KeyedCoProcessOperator constructor
---
.../flink/streaming/api/operators/co/KeyedCoProcessOperator.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java
index 4e2bfc7..c7d981c 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java
@@ -53,8 +53,8 @@ public class KeyedCoProcessOperator<K, IN1, IN2, OUT>
private transient OnTimerContextImpl<IN1, IN2, OUT> onTimerContext;
- public KeyedCoProcessOperator(CoProcessFunction<IN1, IN2, OUT> flatMapper) {
- super(flatMapper);
+ public KeyedCoProcessOperator(CoProcessFunction<IN1, IN2, OUT> coProcessFunction) {
+ super(coProcessFunction);
}
@Override