为了更快的定位您的问题,请提供以下信息,谢谢
【详述】Caused by: java.io.IOException: Unable to flush data to StarRocks: unknown result status, usually caused by: 1.authorization or permission related problems. 2.Wrong column_separator or row_delimiter. 3.Column count exceeded the limitation.
【背景】flink1.14同步mysql到starrocks,只同步一张表,sql如下:
set CHECKPOINT_TIMEOUT= ‘1000 s’;
CREATE TABLE IF NOT EXISTS cvm_price_factor_sink (
Id BIGINT,
Region STRING,
SelfVersionNo BIGINT,
NextVersionNo BIGINT,
ChargeDetailType INT,
Multi DECIMAL,
Div DECIMAL,
PRIMARY KEY (Id, Region) NOT ENFORCED
) WITH (
‘connector’ = ‘starrocks’,
‘sink.max-retries’ = ‘10’,
‘sink.properties.strip_outer_array’ = ‘true’,
‘sink.properties.format’ = ‘json’,
‘sink.buffer-flush.max-rows’ = ‘1000000’,
‘sink.buffer-flush.interval-ms’ = ‘60000’,
‘jdbc-url’ = ‘jdbc:mysql://xxx:9030’,
‘username’ = ‘root’,
‘password’ = ‘xxx’,
‘load-url’ = ‘xxx:8030’,
‘database-name’ = ‘dev_int1_brp_oss’,
‘table-name’ = ‘cvm_price_factor’,
‘sink.version’ = ‘V1’);
CREATE TABLE IF NOT EXISTS cvm_price_factor_src_dev (
Id BIGINT,
Region STRING,
SelfVersionNo BIGINT,
NextVersionNo BIGINT,
ChargeDetailType INT,
Multi DECIMAL,
Div DECIMAL,
PRIMARY KEY (Id, Region) NOT ENFORCED
) WITH (
‘connector’ = ‘mysql-cdc’,
‘server-time-zone’ = ‘Asia/Shanghai’,
‘hostname’ = ‘xxx’,
‘port’ = ‘3306’,
‘username’ = ‘root’,
‘password’ = ‘xxx’,
‘database-name’ = ‘dev_int1_brp_oss’,
‘table-name’ = ‘cvm_price_factor’);
insert into cvm_price_factor_sink select * from cvm_price_factor_src_dev;
【业务影响】
【是否存算分离】
【StarRocks版本】3.1.2
【集群规模】3fe+3be