dinky:
EXECUTE CDCSOURCE jobname WITH (
‘connector’ = ‘mysql-cdc’,
‘hostname’ = ‘xxxxx’,
‘port’ = ‘3306’,
‘username’ = ‘root’,
‘password’ = ‘aiwzj@123!’,
‘checkpoint’ = ‘3000’,
‘scan.startup.mode’ = ‘initial’,
‘parallelism’ = ‘4’,
‘table-name’ = ‘lzs-ad.t_back_data’,
‘server-id’=‘5400-5499’,
‘sink.connector’ = ‘starrocks’,
‘sink.jdbc-url’ = ‘jdbc:mysql://xxxx:9030’,
‘sink.load-url’ = ‘bigdata01:8029’,
‘sink.username’ = ‘root’,
‘sink.password’ = ‘xxxxx’,
‘sink.sink.db’ = ‘ods_ocpx’,
‘sink.table.prefix’ = ‘ods_ocpx_’,
‘sink.table.lower’ = ‘true’,
‘sink.database-name’ = ‘ods_ocpx’,
‘sink.table-name’ = ‘#{tableName}’,
‘sink.sink.properties.format’ = ‘json’,
‘sink.sink.properties.strip_outer_array’ = ‘true’,
‘sink.sink.max-retries’ = ‘10’,
‘sink.sink.buffer-flush.interval-ms’ = ‘15000’,
‘sink.sink.parallelism’ = ‘4’
)`
flink conector/flink cdc
无论是flink cdc ,dinky,还是connector 都是中文乱码。flink conf.yaml 和提交代码时，都有配置UTF-8，但是没什么用。依然乱码。
乱码如下：
说明：StarRocks 3.4.0,flink 1.19.1