This is an automated email from the ASF dual-hosted git repository. leonard pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 96c64a114e3565b96d88f29b598ae53360074b04 Author: Qingsheng Ren <[email protected]> AuthorDate: Fri Feb 11 11:58:30 2022 +0800 [hotfix][connector/common] Fix typo of variable in SourceOperator (cherry picked from commit c81fff6d27c6fc599e0f740f1850d63d5f078413) --- .../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 0866a52..796defb 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 @@ -153,7 +153,7 @@ public class SourceOperator<OUT, SplitT extends SourceSplit> extends AbstractStr private InternalSourceReaderMetricGroup sourceMetricGroup; - private @Nullable LatencyMarkerEmitter<OUT> latencyMarerEmitter; + private @Nullable LatencyMarkerEmitter<OUT> latencyMarkerEmitter; public SourceOperator( FunctionWithException<SourceReaderContext, SourceReader<OUT, SplitT>, Exception> @@ -309,8 +309,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(); } super.finish(); @@ -384,7 +384,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,
