[
https://issues.apache.org/jira/browse/FLINK-40747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser resolved FLINK-40747.
------------------------------------
Fix Version/s: (was: jdbc-4.1.1)
Resolution: Fixed
Fixed in apache/flink-connector-jdbc:main
6b1c277396fb6ac96461b3efa02ef5da4a1f6ef9
> PreparedSplitterEnumerator.of(sqlTemplate) produces no split, the source
> reads nothing
> --------------------------------------------------------------------------------------
>
> Key: FLINK-40747
> URL: https://issues.apache.org/jira/browse/FLINK-40747
> Project: Flink
> Issue Type: Bug
> Components: Connectors / JDBC
> Affects Versions: jdbc-4.1.0
> Reporter: Martijn Visser
> Assignee: Martijn Visser
> Priority: Major
> Labels: pull-request-available
> Fix For: jdbc-5.0.0
>
>
> The single-argument factory builds the enumerator with an empty parameter
> matrix and `SqlSplitterEnumerator` makes one split per row, so a query
> without parameters yields no split and the job finishes without reading a row
> and without an error. It is the first example in the `JdbcSourceBuilder`
> class javadoc and in the docs update of FLINK-40273. Fix: one empty parameter
> row, which the reader binds as no parameters. `SlideTimingSplitterEnumerator`
> keeps relying on the empty-matrix → no-split rule between windows, so the
> base class is unchanged.
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
