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)
