From 31c6b3b80c6b15885654e56a67686a0901cde0a6 Mon Sep 17 00:00:00 2001 From: Kexiang Wang Date: Sun, 22 Sep 2024 23:27:43 -0400 Subject: [PATCH] fix fmt --- .../com/risingwave/connector/source/common/DbzSourceUtils.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/DbzSourceUtils.java b/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/DbzSourceUtils.java index 5363529e9478e..e0670cb7cb8ef 100644 --- a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/DbzSourceUtils.java +++ b/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/DbzSourceUtils.java @@ -62,7 +62,8 @@ 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 + // Note: the value returned here is `pubviaroot`, If there's more than one row, the + // publication exists if (res.next()) { isPubExist = true; }