fixed

sunxiaojian · Nov 15, 2023 · b4fc44c · b4fc44c
1 parent ca9d380
commit b4fc44c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...c/pulsar/PulsarSyncTableActionITCase.java → ...sar/PulsarCanalSyncTableActionITCase.java b/...c/pulsar/PulsarSyncTableActionITCase.java → ...sar/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/...t/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarDebeziumSyncTableActionITCase.java b/...t/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(