[FLINK-36895] The JdbcSourceChunkSplitter#queryMin method passed a pa…

…rameter with tableName/coiumnName reversed.
apache · Dec 12, 2024 · c93ea5d · c93ea5d
1 parent 2e54caf
commit c93ea5d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rg/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java b/...rg/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java
@@ -256,8 +256,8 @@ protected Object queryMin(
             throws SQLException {
         return JdbcChunkUtils.queryMin(
                 jdbc,
-                jdbc.quotedColumnIdString(splitColumn.name()),
                 jdbc.quotedTableIdString(tableId),
+                jdbc.quotedColumnIdString(splitColumn.name()),
                 excludedLowerBound);
     }