[
https://issues.apache.org/jira/browse/FLINK-41105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-41105:
-------------------------------
Attachment: fix.patch
> transform projection: arithmetic between DECIMAL column and numeric literal
> fails at Janino compile time — times(BigDecimal, double) has no matching
> overload
> -------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-41105
> URL: https://issues.apache.org/jira/browse/FLINK-41105
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.6.0
> Environment: - Flink CDC 3.6.0 (pipeline mode, MySQL → Doris)
> - Source column: MySQL `DECIMAL(10,2)` → Flink CDC `BigDecimal`
> - `ArithmeticFunctions.times/plus/minus/divides` still only have
> same-type-pair overloads
> Reporter: zhanglu153
> Priority: Critical
> Labels: Flink-CDC
> Attachments: fix.patch
>
>
> When a CDC pipeline transform projection contains an arithmetic computed
> column between a *DECIMAL column and a numeric literal* (e.g. {{price *
> 1.13}}, a pattern explicitly promised by the official Arithmetic Functions
> table and used in the 3.1 release announcement example {{weight / (height *
> height) as bmi}}), the job passes schema derivation and table creation, but
> fails at runtime on the *first DataChangeEvent* with a Janino
> {{CompileException}}: no matching overload for {{(BigDecimal, double)}}. The
> job then restarts forever and can never complete. The product's own error
> message says: _"Expression cannot be compiled. This is a bug. Please file an
> issue."_
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
