fix incorrect method name (streamnative#346)

Co-authored-by: 高章敏 <[email protected]>
gaozhangmin · Jun 8, 2021 · 70d7ab1 · 70d7ab1
1 parent b304b04
commit 70d7ab1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...or/src/main/java/org/apache/flink/streaming/connectors/pulsar/internal/PulsarFetcher.java b/...or/src/main/java/org/apache/flink/streaming/connectors/pulsar/internal/PulsarFetcher.java
@@ -417,7 +417,7 @@ protected void doCommitOffsetToPulsar(
             boolean success = false;
             while (running) {
                 try {
-                    metadataReader.commitCursorToOffset(offset);
+                    metadataReader.commitOffsetToCursor(offset);
                     success = true;
                     break;
                 } catch (Exception e) {

diff --git a/...main/java/org/apache/flink/streaming/connectors/pulsar/internal/PulsarMetadataReader.java b/...main/java/org/apache/flink/streaming/connectors/pulsar/internal/PulsarMetadataReader.java
@@ -238,7 +238,7 @@ public void setupCursor(Map<TopicRange, MessageId> offset) {
         setupCursor(offset, true);
     }
 
-    public void commitCursorToOffset(Map<TopicRange, MessageId> offset) {
+    public void commitOffsetToCursor(Map<TopicRange, MessageId> offset) {
         for (Map.Entry<TopicRange, MessageId> entry : offset.entrySet()) {
             TopicRange tp = entry.getKey();
             try {