You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by le...@apache.org on 2022/03/28 09:52:49 UTC
[flink] 01/02: [hotfix][connector/common] Fix typo of variable in SourceOperator
This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 28228acd3007d9d3e09c19a61a5670748c15faed
Author: Qingsheng Ren <re...@gmail.com>
AuthorDate: Fri Feb 11 11:58:30 2022 +0800
[hotfix][connector/common] Fix typo of variable in SourceOperator
---
.../org/apache/flink/streaming/api/operators/SourceOperator.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java
index aba2085..5660bc1 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java
@@ -170,7 +170,7 @@ public class SourceOperator<OUT, SplitT extends SourceSplit> extends AbstractStr
private CompletableFuture<Void> waitingForAlignmentFuture =
CompletableFuture.completedFuture(null);
- private @Nullable LatencyMarkerEmitter<OUT> latencyMarerEmitter;
+ private @Nullable LatencyMarkerEmitter<OUT> latencyMarkerEmitter;
public SourceOperator(
FunctionWithException<SourceReaderContext, SourceReader<OUT, SplitT>, Exception>
@@ -334,8 +334,8 @@ public class SourceOperator<OUT, SplitT extends SourceSplit> extends AbstractStr
if (eventTimeLogic != null) {
eventTimeLogic.stopPeriodicWatermarkEmits();
}
- if (latencyMarerEmitter != null) {
- latencyMarerEmitter.close();
+ if (latencyMarkerEmitter != null) {
+ latencyMarkerEmitter.close();
}
}
@@ -433,7 +433,7 @@ public class SourceOperator<OUT, SplitT extends SourceSplit> extends AbstractStr
.getConfiguration()
.getLong(MetricOptions.LATENCY_INTERVAL);
if (latencyTrackingInterval > 0) {
- latencyMarerEmitter =
+ latencyMarkerEmitter =
new LatencyMarkerEmitter<>(
getProcessingTimeService(),
output::emitLatencyMarker,