Martijn Visser created FLINK-40743:
--------------------------------------
Summary: JDBC Table sink reports an empty lineage dataset name
Key: FLINK-40743
URL: https://issues.apache.org/jira/browse/FLINK-40743
Project: Flink
Issue Type: Bug
Components: Connectors / JDBC
Affects Versions: jdbc-4.1.0, jdbc-4.0.0
Reporter: Martijn Visser
Assignee: Martijn Visser
Fix For: jdbc-5.0.0
`TableLineageUtils.extractLineageDataset` runs at plan time on the object
`SinkFunctionProvider.createSinkFunction()` returns.
`JdbcOutputFormat.getLineageVertex()` reads the statement text from the
transient statement executor, which only exists after `open()`, so the dataset
name is always `""` for Table sinks (the DataStream `JdbcSink` is fine).
Fix: give the format the dialect's INSERT statement at build time. See also
FLINK-39935 (planner-side override of the dataset name; independent).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
