目前使用flink 1.14.5通过flink-doris-connector-1.14_2.11访问doris-2.1.6表数据时执行flink sql：select * from productLine_doris_sink直接提示 org.apache.doris.flink.exception.DorisException: Load Doris data failed, schema size of fetch data is wrong.
相关依赖包信息如图：
相关建表语句如下
flink 建表语句：
tableEnv.executeSql(
"CREATE TABLE productLine_doris_sink ( " +
"ID BIGINT NOT NULL, " +
"Name STRING NOT NULL, " +
"ServiceTeamID BIGINT, " +
"QuotationMode INT NOT NULL, " +
"Description STRING, " +
"NeedSaleForecastProject BOOLEAN, " +
"QuotationType INT NOT NULL, " +
"NeedServiceSale BOOLEAN NOT NULL, " +
"NeedUploadFile BOOLEAN NOT NULL, " +
"NeedJoinSameProductInISC BOOLEAN NOT NULL, " +
"BusinessUnitId BIGINT, " +
"CanCreateInnerServiceType4 BOOLEAN, " +
"State INT NOT NULL " +
") WITH ( " +
" 'connector' = 'doris', " +
" 'fenodes' = 'xx.xx.xx.xx:8030', " +
" 'table.identifier' = 'edm.productLine', " + // 目标表所在位置
" 'username' = 'xxx', " +
" 'password' = 'xxx', " +
" 'sink.label-prefix' = 'business_1' " +
")"
);
doris 建表语句：
CREATE TABLE productLine (
ID BIGINT NOT NULL,
Name STRING NOT NULL,
ServiceTeamID BIGINT,
QuotationMode INT NOT NULL,
Description STRING,
NeedSaleForecastProject BOOLEAN,
QuotationType INT NOT NULL,
NeedServiceSale BOOLEAN NOT NULL,
NeedUploadFile BOOLEAN NOT NULL,
NeedJoinSameProductInISC BOOLEAN NOT NULL,
BusinessUnitId BIGINT,
CanCreateInnerServiceType4 BOOLEAN,
State INT NOT NULL
) UNIQUE KEY (ID)
comment '明细数据表'
DISTRIBUTED BY HASH(ID) BUCKETS 2
PROPERTIES ("replication_num" = "3");
