[
https://issues.apache.org/jira/browse/FLINK-36741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36741:
-------------------------------
Fix Version/s: cdc-3.3.0
> The precision of Decimal has been lost when use FlinkCDC transform
> -------------------------------------------------------------------
>
> Key: FLINK-36741
> URL: https://issues.apache.org/jira/browse/FLINK-36741
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.2.0
> Reporter: Wenkai Qi
> Assignee: Wenkai Qi
> Priority: Major
> Labels: pull-request-available
> Fix For: cdc-3.3.0
>
> Original Estimate: 24h
> Remaining Estimate: 24h
>
> The precision and scale of Decimal has been lost when use FlinkCDC transform
> to project express or alias.
> The fields of this table are as follows:
> ||column name||data type||
> |id|int|
> |name|string|
> |age|int|
> |address|string|
> |deposit|decimal(10,2)|
> |weight|double|
> |height|double|
> The projection rule of this pipeline are as follows:
> {code:java}
> projection: id, upper(name) as name, age + 1 as newage, deposit as deposits,
> weight / (height * height) as bmi {code}
> The parsed data types are as follows:
> ||column name||data type||
> |id|int|
> |name|string|
> |newage|int|
> |deposits|decimal(19,0)|
> |bmi|double|
> The expected data type of deposits should be decimal(10,2).
> I have fixed it, and I will pull request.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
