From b4fc44c74b52b407de119abd2a98f14940d34a4b Mon Sep 17 00:00:00 2001
From: sunxiaojian <sunxiaojian926@163.com>
Date: Wed, 15 Nov 2023 10:02:17 +0800
Subject: [PATCH] fixed

---
 ...eActionITCase.java => PulsarCanalSyncTableActionITCase.java} | 2 +-
 .../action/cdc/pulsar/PulsarDebeziumSyncTableActionITCase.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
 rename paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/pulsar/{PulsarSyncTableActionITCase.java => PulsarCanalSyncTableActionITCase.java} (99%)

diff --git a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableActionITCase.java b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarCanalSyncTableActionITCase.java
similarity index 99%
rename from paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableActionITCase.java
rename to paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarCanalSyncTableActionITCase.java
index a39507b5f5378..0e83bb800229d 100644
--- a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableActionITCase.java
+++ b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarCanalSyncTableActionITCase.java
@@ -35,7 +35,7 @@
 import static org.apache.paimon.flink.action.cdc.pulsar.PulsarActionUtils.VALUE_FORMAT;
 
 /** IT cases for {@link PulsarSyncTableAction}. */
-public class PulsarSyncTableActionITCase extends PulsarActionITCaseBase {
+public class PulsarCanalSyncTableActionITCase extends PulsarActionITCaseBase {
 
     @Test
     @Timeout(120)
diff --git a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarDebeziumSyncTableActionITCase.java b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarDebeziumSyncTableActionITCase.java
index fbf927032dbe1..5fd5909a62e42 100644
--- a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarDebeziumSyncTableActionITCase.java
+++ b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarDebeziumSyncTableActionITCase.java
@@ -47,7 +47,7 @@ public void testSchemaEvolution() throws Exception {
     private void runSingleTableSchemaEvolution(String sourceDir) throws Exception {
         final String topic = "schema_evolution";
         createTopic(topic, 1);
-        // ---------- Write the debezium json into Kafka -------------------
+        // ---------- Write the debezium json into Pulsar -------------------
         sendMessages(
                 topic,
                 getMessages(