[hotfix][connector/common] Fix typo of variable in SourceOperator

bbejeck · Mar 15, 2022 · c81fff6 · c81fff6
1 parent 092647c
commit c81fff6
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java b/...streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java
@@ -170,7 +170,7 @@ private enum OperatingMode {
  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 @@ private void stopInternalServices() {
  if (eventTimeLogic != null) {
  eventTimeLogic.stopPeriodicWatermarkEmits();
  }
- if (latencyMarerEmitter != null) {
- latencyMarerEmitter.close();
+ if (latencyMarkerEmitter != null) {
+ latencyMarkerEmitter.close();
  }
  }
 
@@ -433,7 +433,7 @@ private void initializeLatencyMarkerEmitter(DataOutput<OUT> output) {
  .getConfiguration()
  .getLong(MetricOptions.LATENCY_INTERVAL);
  if (latencyTrackingInterval > 0) {
- latencyMarerEmitter =
+ latencyMarkerEmitter =
  new LatencyMarkerEmitter<>(
  getProcessingTimeService(),
  output::emitLatencyMarker,