Xiao Huang created FLINK-37429:
----------------------------------
Summary: Map each original column name to a new name and support
column name containing '-'
Key: FLINK-37429
URL: https://issues.apache.org/jira/browse/FLINK-37429
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.3.0
Reporter: Xiao Huang
Fix For: cdc-3.4.0
At present, Flink CDC uses janino to evaluate value for expressions in
transform operator. However, the generated expression codes use original column
name as variable name, which cannot support columns whose name does not conform
the standard for java variable names (e.g. `timestamp-type`).
This problem can be solved by mapping each column name to a new name when
generating expression code.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
