[flink] 12/16: [hotfix][operator] Fix checkpointing lock in StreamTwoInputSelectableProcessor

[pnowojski]

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 <piotr.nowoj...@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,