MOBIN created FLINK-36754:
-----------------------------
Summary: When projection is empty or null, it is treated as an
asterisk
Key: FLINK-36754
URL: https://issues.apache.org/jira/browse/FLINK-36754
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.2.0
Reporter: MOBIN
When projection is empty or NULL, the projection should be treated as an
asterisk. The following transform rule should throw an exception [different
column counts], but the actual schema columns are id and name, which is not
expected.
{code:java}
transform:
- source-table: testdb.test_table1
filter: age> 8 and age < 18
- source-table: testdb.test_table1
projection: id,UPPER(name) AS name
filter: age >= 18 {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)