[
https://issues.apache.org/jira/browse/FLINK-36895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang reassigned FLINK-36895:
---------------------------------
Assignee: ouyangwulin
> 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
> Assignee: ouyangwulin
> Priority: Major
> Labels: pull-request-available
> 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)
