[
https://issues.apache.org/jira/browse/FLINK-35852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872192#comment-17872192
]
yux commented on FLINK-35852:
-----------------------------
Resolved in https://github.com/apache/flink-cdc/pull/3285.
> When used through the transform function, the decimal(10,2) type field value
> in the MySQL source table becomes 100 times the original value after being
> transferred to the target table.
> ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-35852
> URL: https://issues.apache.org/jira/browse/FLINK-35852
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.1.1
> Environment: flink-1.18.0、
> flink-cdc-3.1.1、mysql-5.7.43、Doris-2.0.6、CentOS Linux release 8.5.2111
> Reporter: zheng_shengsheng
> Priority: Major
> Attachments: image-2024-07-16-14-46-53-982.png,
> image-2024-07-16-14-48-07-981.png
>
>
> When I use CDC's yaml mode to collect MySQL data to Doris, I use the latest
> supported transform feature.
> Finally, I found that the database table in MySQL collected and the
> decimal(10,2) type fields in the Mysql source table were automatically
> converted into decimal(19,0) in Doris, and then the value size became 100
> times the original size. As follows
>
> !image-2024-07-16-14-48-07-981.png!
> !image-2024-07-16-14-46-53-982.png!
>
> The core part of yaml is as follows:
> {code:java}
> // code placeholder
> source:
> type: mysql
> hostname: node2
> port: 3306
> username: ****
> password: ****
> tables: sys_canteen_consume_conf,sys_canteen_consume_rec,sys_order_course,
> server-id: 5513
> connectionTimeZone: GMT+8
> scan.startup.mode: initial
> sink:
> type: doris
> fenodes: node3:8030
> username: admin
> password: ****
> table.create.properties.light_schema_change: true
> table.create.properties.replication_num: 1
> transform:
> - source-table: jeecg-boot2.sys_\.*
> projection: concat('LYDB2','') as tenant_code, *
> primary-keys: tenant_code,id
> - source-table: jeecg-boot2.sys_user_depart
> projection: concat('LYDB2','') as tenant_code, *
> primary-keys: tenant_code,ID
> pipeline:
> name: test，server-id-5513,flinkCDC-3.1.1
> parallelism: 1 {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
