comments addressed

apache · Jun 4, 2023 · 4ebdbb6 · 4ebdbb6
1 parent b49f10e
commit 4ebdbb6
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/...r-oceanbase-cdc/src/main/java/com/ververica/cdc/connectors/oceanbase/OceanBaseSource.java b/...r-oceanbase-cdc/src/main/java/com/ververica/cdc/connectors/oceanbase/OceanBaseSource.java
@@ -187,7 +187,7 @@ public SourceFunction<T> build() {
                     && (StringUtils.isNotEmpty(databaseName)
                             || StringUtils.isNotEmpty(tableName))) {
                 throw new IllegalArgumentException(
-                        "'database-name' and 'table-name' should be configured with 'INITIAL' mode");
+                        "If startup mode is not 'INITIAL', 'database-name' and 'table-name' must not be configured");
             }
             if (StringUtils.isNotEmpty(databaseName) || StringUtils.isNotEmpty(tableName)) {
                 if (StringUtils.isEmpty(databaseName) || StringUtils.isEmpty(tableName)) {

diff --git a/.../main/java/com/ververica/cdc/connectors/oceanbase/source/OceanBaseRichSourceFunction.java b/.../main/java/com/ververica/cdc/connectors/oceanbase/source/OceanBaseRichSourceFunction.java
@@ -225,7 +225,11 @@ private void initTableWhiteList() {
                 LOG.info("Pattern matched tables: {}", matchedTables);
                 localTableSet.addAll(matchedTables);
             } catch (SQLException e) {
-                LOG.error("Query table list by 'databaseName' and 'tableName' failed", e);
+                LOG.error(
+                        String.format(
+                                "Query table list by 'database-name' %s and 'table-name' %s failed.",
+                                databaseName, tableName),
+                        e);
                 throw new FlinkRuntimeException(e);
             }
         }