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

["Mrart (via GitHub)" <gi...@apache.org>]

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

   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 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-unsubscribe@flink.apache.org

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

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

["ruanhang1993 (via GitHub)" <gi...@apache.org>]

ruanhang1993 merged PR #3797:
URL: https://github.com/apache/flink-cdc/pull/3797


-- 
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-unsubscribe@flink.apache.org

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