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:53 UTC
[flink] branch master updated (8340212 -> dd96ca8)
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8340212 [FLINK-22746][docs] Links to connectors in docs are broken
new 6ec5194 [hotfix][runtime] Remove unused field from OperatorChain
new dd96ca8 [FLINK-22780][streaming] Remove volatile from the idle flag in StreamSourceContexts
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/streaming/api/operators/StreamSourceContexts.java | 4 ++--
.../org/apache/flink/streaming/runtime/tasks/OperatorChain.java | 8 --------
2 files changed, 2 insertions(+), 10 deletions(-)
[flink] 01/02: [hotfix][runtime] Remove unused field from
OperatorChain
Posted by dw...@apache.org.
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 6ec5194519d7d751b4e95cb5dfa96878039ab532
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Thu May 27 13:39:07 2021 +0200
[hotfix][runtime] Remove unused field from OperatorChain
---
.../org/apache/flink/streaming/runtime/tasks/OperatorChain.java | 8 --------
1 file changed, 8 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
index 10f74b9..25270bb 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
@@ -49,7 +49,6 @@ import org.apache.flink.streaming.api.operators.StreamTaskStateInitializer;
import org.apache.flink.streaming.runtime.io.RecordWriterOutput;
import org.apache.flink.streaming.runtime.io.StreamTaskSourceInput;
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
-import org.apache.flink.streaming.runtime.streamstatus.StreamStatus;
import org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorFactory;
import org.apache.flink.util.FlinkException;
import org.apache.flink.util.OutputTag;
@@ -129,13 +128,6 @@ public class OperatorChain<OUT, OP extends StreamOperator<OUT>> implements Bound
private boolean ignoreEndOfInput;
- /**
- * Current status of the input stream of the operator chain. Watermarks explicitly generated by
- * operators in the chain (i.e. timestamp assigner / watermark extractors), will be blocked and
- * not forwarded if this value is {@link StreamStatus#IDLE}.
- */
- private StreamStatus streamStatus = StreamStatus.ACTIVE;
-
public OperatorChain(
StreamTask<OUT, OP> containingTask,
RecordWriterDelegate<SerializationDelegate<StreamRecord<OUT>>> recordWriterDelegate) {
[flink] 02/02: [FLINK-22780][streaming] Remove volatile from the
idle flag in StreamSourceContexts
Posted by dw...@apache.org.
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,