为了更快的定位您的问题,请提供以下信息,谢谢
【详述】
根据官网 通过导入实现数据变更 | StarRocks,使用Broker Load导入时,score报错显示Column has no default value. column: score
【背景】使用Broker Load导入数据
【业务影响】
【是否存算分离】
【StarRocks版本】3.1
【connector版本】flink-connector 1.2 或者spark-connector 1.2
【集群规模】例如:3fe(1 follower+2observer)+3be(fe与be混部)
【机器信息】CPU虚拟核/内存/网卡,例如:48C/64G/万兆
【联系方式】为了在解决问题过程中能及时联系到您获取一些日志信息,请补充下您的联系方式,例如:社区群4-小李或者邮箱,谢谢
【附件】
- 导入报错
创表语句
CREATE TABLEtable4
(
id
int(11) NOT NULL COMMENT “用户 ID”,
name
varchar(65533) NOT NULL COMMENT “用户姓名”,
score
int(11) NOT NULL COMMENT “用户得分”
)
ENGINE=OLAP
PRIMARY KEY(id
)
DISTRIBUTED BY HASH(id
);
导入语句
LOAD LABEL test.table4
(
DATA INFILE(“hdfs://<hdfs_host>:<hdfs_port>/starrocks/example4.csv”)
INTO TABLE table4
COLUMNS TERMINATED BY “,”
FORMAT AS “csv”
(id, name)
)
WITH BROKER
PROPERTIES
(
“partial_update” = “true”
);
通过SHOW LOAD \G看到报错
JobId: 22405
Label: table4
State: CANCELLED
Progress: ETL:N/A; LOAD:N/A
Type: BROKER
Priority: NORMAL
ScanRows: 0
FilteredRows: 0
UnselectedRows: 0
SinkRows: 0
EtlInfo: NULL
TaskInfo: resource:N/A; timeout(s):14400; max_filter_ratio:0.0
ErrorMsg: type:ETL_RUN_FAIL; msg:Column has no default value. column: score
CreateTime: 2024-01-23 15:56:42
EtlStartTime: NULL
EtlFinishTime: NULL
LoadStartTime: NULL
LoadFinishTime: 2024-01-23 15:56:43
TrackingSQL:
JobDetails: {“All backends”:{},“FileNumber”:1,“FileSize”:28,“InternalTableLoadBytes”:0,“InternalTableLoadRows”:0,“ScanBytes”:0,“ScanRows”:0,“TaskNumber”:0,“Unfinished backends”:{}}
使用Runtine Load和Stream Load可以实现id、name列的更新。