[
https://issues.apache.org/jira/browse/FLINK-37429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-37429:
-------------------------------
Summary: Map each original column name to a new name in generated
expression to support column name containing '-' (was: Map each original
column name to a new name and support column name containing '-')
> Map each original column name to a new name in generated expression to
> 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
> Priority: Minor
> 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)