Flink CDC Issue Import created FLINK-34885: ----------------------------------------------
Summary: mysql to sr pipeline, float value bug Key: FLINK-34885 URL: https://issues.apache.org/jira/browse/FLINK-34885 Project: Flink Issue Type: Bug Components: Flink CDC Reporter: Flink CDC Issue Import env: flink 1.18.1 flinkcdc 3.0.1 starrocks: 3.2.3 mysql: 5.6.* xxx.yaml : `pipeline: {name: 5411_total_info_to_sr, parallelism: 1} route: null sink: {jdbc-url: 'jdbc:mysql://172.16.100.40:9030', load-url: '172.16.100.40:8030', name: StarRocks Sink, password:*******, properties.properties.max_filter_ratio: 0.9, properties.properties.strict_mode: false, table.create.properties.replication_num: 1, type: starrocks, username: ******} source: {hostname: mysql-cluster.internal.******.com, password:******, port: 3306, scan.startup.mode: timestamp, scan.startup.timestamp-millis: 1710233721754, schema-change.enabled: false, server-id: 5411, server-time-zone: Asia/Shanghai, tables: 'enlightent_daily.\.*_total_info,enlightent_daily.\.video_basic_info', type: mysql, username:******}` comand: bin/flink-cdc.sh xxx.yaml bug: the fileds of float type are error,the fileds of double type are right. then I try myql-cdc alone, the values print right on the flink sql client screen. then I try create flink table for source table(mysql) and sink table(starrocks) on flink sql client. `insert into master_cost_float_sr select * from master_cost_float/*+ OPTIONS('server-id'='5801-5804') */; [INFO] Submitting SQL update statement to the cluster... [INFO] SQL update statement has been successfully submitted to the cluster: Job ID: 14620b59ae166ea75a6ab3eda071872f ` by this way, the float fields are right for cdc. ---------------- Imported from GitHub ---------------- Url: https://github.com/apache/flink-cdc/issues/3132 Created by: [dickson-bit|https://github.com/dickson-bit] Labels: Created at: Wed Mar 13 11:20:48 CST 2024 State: open -- This message was sent by Atlassian Jira (v8.20.10#820010)