[hotfix][mysql] Rename method from dispatchHighWatermark to dispatchBinlogEndEvent (#810)

This closes #810.
3 years ago · e70e0f1b68
parent 7455ad63ab
commit e70e0f1b68
1 changed files with 2 additions and 2 deletions
--- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java
+++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java
@ -124,7 +124,7 @@ public class SnapshotSplitReader implements DebeziumReader<SourceRecord, MySqlSp
                                        .getEndingOffset()
                                        .isAfter(backfillBinlogSplit.getStartingOffset());
                        if (!binlogBackfillRequired) {
-                            dispatchHighWatermark(backfillBinlogSplit);
+                            dispatchBinlogEndEvent(backfillBinlogSplit);
                            currentTaskRunning = false;
                            return;
                        }
@ -196,7 +196,7 @@ public class SnapshotSplitReader implements DebeziumReader<SourceRecord, MySqlSp
                backfillBinlogSplit);
    }

-    private void dispatchHighWatermark(MySqlBinlogSplit backFillBinlogSplit)
+    private void dispatchBinlogEndEvent(MySqlBinlogSplit backFillBinlogSplit)
            throws InterruptedException {
        final SignalEventDispatcher signalEventDispatcher =
                new SignalEventDispatcher(