[PR] [FLINK-36895] The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed. [flink-cdc]

[via GitHub]

Mrart opened a new pull request, #3796:
URL: https://github.com/apache/flink-cdc/pull/3796

   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".
   
   we need sql "select columnid from tableId"


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org