You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2021/05/27 17:33:55 UTC
[flink] 02/02: [FLINK-22780][streaming] Remove volatile from the
idle flag in StreamSourceContexts
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit dd96ca823332f253e55ad35f29c6fe3909e398d7
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Thu May 27 13:39:51 2021 +0200
[FLINK-22780][streaming] Remove volatile from the idle flag in StreamSourceContexts
---
.../apache/flink/streaming/api/operators/StreamSourceContexts.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSourceContexts.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSourceContexts.java
index 9b66437..990585f 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSourceContexts.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSourceContexts.java
@@ -142,7 +142,7 @@ public class StreamSourceContexts {
private long lastRecordTime;
- private volatile boolean idle = false;
+ private boolean idle = false;
private AutomaticWatermarkContext(
final Output<StreamRecord<T>> output,
@@ -300,7 +300,7 @@ public class StreamSourceContexts {
private final Output<StreamRecord<T>> output;
private final StreamRecord<T> reuse;
- private volatile boolean idle = false;
+ private boolean idle = false;
private ManualWatermarkContext(
final Output<StreamRecord<T>> output,