fix(pg-cdc): fix postgres.publication_exist, found in issues#18628 (#…

…18629)
risingwavelabs · Sep 24, 2024 · e745820 · e745820
1 parent 27458d8
commit e745820
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...onnector-service/src/main/java/com/risingwave/connector/source/common/DbzSourceUtils.java b/...onnector-service/src/main/java/com/risingwave/connector/source/common/DbzSourceUtils.java
@@ -62,8 +62,10 @@ public static void createPostgresPublicationIfNeeded(
                             ValidatorUtils.getSql("postgres.publication_exist"))) {
                 stmt.setString(1, pubName);
                 var res = stmt.executeQuery();
+                // Note: the value returned here is `pubviaroot`, If there's more than one row, the
+                // publication exists
                 if (res.next()) {
-                    isPubExist = res.getBoolean(1);
+                    isPubExist = true;
                 }
             }