通过StreamLoad，批量导入json格式的数据到 更新模型表，失败

[RayYang]

表结构

导入数据失败提示， trd_code is null？？？

[Natsume729]

麻烦脱敏发下建表语句和一条json样例数据呢

[RayYang]

CREATE TABLE IF NOT EXISTS test_b (
id bigint not null COMMENT “id”,
trd_dt date NOT NULL COMMENT “trate date”,
trd_code BIGINT NOT NULL COMMENT “trade code”,
cls_prc float COMMENT “close price”,
high_prc float COMMENT “high price”,
low_prc float COMMENT “low price”,
open_prc float COMMENT “low price”
)
UNIQUE KEY(id,trd_dt, trd_code)
DISTRIBUTED BY HASH(trd_code) BUCKETS 3;

[{"low_prc":109.46,"high_prc":110.46,"cls_prc":110.46,"trd_code":"601001.SH","id":32,"open_prc":108.46,"trd_dt":"2021-10-29 00:00:00"},{"low_prc":109.46,"high_prc":111.46,"cls_prc":110.46,"trd_code":"601001.SH","id":33,"open_prc":108.46,"trd_dt":"2021-10-29 00:00:00"},{"low_prc":109.46,"high_prc":112.46,"cls_prc":110.46,"trd_code":"601001.SH","id":34,"open_prc":108.46,"trd_dt":"2021-10-29 00:00:00"},{"low_prc":109.46,"high_prc":113.46,"cls_prc":110.46,"trd_code":"601001.SH","id":35,"open_prc":108.46,"trd_dt":"2021-10-29 00:00:00"},{"low_prc":109.46,"high_prc":114.46,"cls_prc":110.46,"trd_code":"601001.SH","id":36,"open_prc":108.46,"trd_dt":"2021-10-29 00:00:00"},{"low_prc":109.46,"high_prc":115.46,"cls_prc":110.46,"trd_code":"601001.SH","id":37,"open_prc":108.46,"trd_dt":"2021-10-29 00:00:00"},{"low_prc":109.46,"high_prc":116.46,"cls_prc":110.46,"trd_code":"601001.SH","id":38,"open_prc":108.46,"trd_dt":"2021-10-29 00:00:00"},{"low_prc":109.46,"high_prc":117.46,"cls_prc":110.46,"trd_code":"601001.SH","id":39,"open_prc":108.46,"trd_dt":"2021-10-29 00:00:00"},{"low_prc":109.46,"high_prc":118.46,"cls_prc":110.46,"trd_code":"601001.SH","id":40,"open_prc":108.46,"trd_dt":"2021-10-29 00:00:00"},{"low_prc":109.46,"high_prc":119.46,"cls_prc":110.46,"trd_code":"601001.SH","id":41,"open_prc":108.46,"trd_dt":"2021-10-29 00:00:00"}]

[RayYang]

可能是数据库trd_code字段类型设置错了！！

[RayYang]

果然是字段类型和数据不匹配导致的~~~