[
https://issues.apache.org/jira/browse/FLINK-36895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36895:
------------------------------
Affects Version/s: cdc-3.1.0
> 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: cdc-3.1.0, cdc-3.2.0
> Reporter: ouyangwulin
> Assignee: ouyangwulin
> Priority: Major
> Labels: pull-request-available
> Fix For: cdc-3.3.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)
