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 <[email protected]> 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,
