[jira] [Created] (FLINK-36895) The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed.

[ouyangwulin (Jira)]

ouyangwulin created FLINK-36895:
-----------------------------------

             Summary: The JdbcSourceChunkSplitter#queryMin method passed a 
parameter with tableName/coiumnName reversed.
                 Key: FLINK-36895
                 URL: https://issues.apache.org/jira/browse/FLINK-36895
             Project: Flink
          Issue Type: Bug
          Components: Flink CDC
    Affects Versions: 3.0.0
            Reporter: ouyangwulin
             Fix For: 3.0.0
         Attachments: split_error.jpg

JdbcChunkUtils#queryMin()
final String minQuery =
String.format(
"SELECT MIN(%s) FROM %s WHERE %s > ?",
quotedColumnName, quotedTableName, quotedColumnName);
 
but JdbcSourceChunkSplitter #queryMin
 
protected Object queryMin(
JdbcConnection jdbc, TableId tableId, Column splitColumn, Object 
excludedLowerBound)
throws SQLException {
return JdbcChunkUtils.queryMin(
jdbc,
jdbc.quotedColumnIdString(splitColumn.name()),
jdbc.quotedTableIdString(tableId),
excludedLowerBound);
}
 
Error passing column/tableId parameter. Resulting in the generated sql "select 
tableId from columnID".



--
This message was sent by Atlassian Jira
(v8.20.10#820010)