fixed

sunxiaojian · Apr 16, 2024 · ad40e4a · ad40e4a
1 parent 0cd01fa
commit ad40e4a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...paimon-flink-cdc/src/main/resources/META-INF/services/org.apache.paimon.factories.Factory b/...paimon-flink-cdc/src/main/resources/META-INF/services/org.apache.paimon.factories.Factory
@@ -25,3 +25,4 @@ org.apache.paimon.flink.action.cdc.pulsar.PulsarSyncDatabaseActionFactory
 org.apache.paimon.flink.action.cdc.mongodb.MongoDBSyncTableActionFactory
 org.apache.paimon.flink.action.cdc.mongodb.MongoDBSyncDatabaseActionFactory
 org.apache.paimon.flink.action.cdc.postgres.PostgresSyncTableActionFactory
+org.apache.paimon.flink.action.cdc.postgres.PostgresSyncDatabaseActionFactory
diff --git a/...aimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/CdcActionITCaseBase.java b/...aimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/CdcActionITCaseBase.java
@@ -26,6 +26,7 @@
 import org.apache.paimon.flink.action.cdc.mongodb.MongoDBSyncTableActionFactory;
 import org.apache.paimon.flink.action.cdc.mysql.MySqlSyncDatabaseActionFactory;
 import org.apache.paimon.flink.action.cdc.mysql.MySqlSyncTableActionFactory;
+import org.apache.paimon.flink.action.cdc.postgres.PostgresSyncDatabaseActionFactory;
 import org.apache.paimon.flink.action.cdc.postgres.PostgresSyncTableActionFactory;
 import org.apache.paimon.flink.action.cdc.pulsar.PulsarSyncDatabaseActionFactory;
 import org.apache.paimon.flink.action.cdc.pulsar.PulsarSyncTableActionFactory;
@@ -232,6 +233,8 @@ private <T> String getActionName(Class<T> clazz) {
                 return PulsarSyncDatabaseActionFactory.IDENTIFIER;
             case "PostgresSyncTableAction":
                 return PostgresSyncTableActionFactory.IDENTIFIER;
+            case "PostgresSyncDatabaseActionFactory":
+                return PostgresSyncDatabaseActionFactory.IDENTIFIER;
             default:
                 throw new UnsupportedOperationException(
                         "Unknown sync action: " + clazz.getSimpleName());