You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2019/07/01 14:41:21 UTC
[flink] 12/16: [hotfix][operator] Fix checkpointing lock in
StreamTwoInputSelectableProcessor
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 530a5e445785df9a85260b2654b776839fc74708
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Thu Jun 20 20:07:47 2019 +0200
[hotfix][operator] Fix checkpointing lock in StreamTwoInputSelectableProcessor
---
.../flink/streaming/runtime/tasks/TwoInputSelectableStreamTask.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputSelectableStreamTask.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputSelectableStreamTask.java
index 1199901..b577b20 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputSelectableStreamTask.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputSelectableStreamTask.java
@@ -49,7 +49,7 @@ public class TwoInputSelectableStreamTask<IN1, IN2, OUT> extends AbstractTwoInpu
this.inputProcessor = new StreamTwoInputSelectableProcessor<>(
inputGates1, inputGates2,
inputDeserializer1, inputDeserializer2,
- this,
+ getCheckpointLock(),
getEnvironment().getIOManager(),
getStreamStatusMaintainer(),
this.headOperator,