StreamLoad 批量加载json格式数据 报错 unknown reference column, column=__op, reference=to_delete

image

提示信息
{
“TxnId”: 124,
“Label”: “77f7cc5c-0e33-49e3-a49e-c676dd6220d7”,
“Status”: “Fail”,
“Message”: “load op type string not supported: is_delete”,
“NumberTotalRows”: 0,
“NumberLoadedRows”: 0,
“NumberFilteredRows”: 0,
“NumberUnselectedRows”: 0,
“LoadBytes”: 0,
“LoadTimeMs”: 0,
“BeginTxnTimeMs”: 1,
“StreamLoadPutTimeMs”: 1,
“ReadDataTimeMs”: 0,
“WriteDataTimeMs”: 0,
“CommitAndPublishTimeMs”: 0
}

代码中指定了 json数据中的op字段是 is_delete
put.setHeader(“columns”,"__op=‘is_delete’ ");

stream load导入json,只需要-H "columns:__op=‘delete’"就可以

因为 to_delete 不属于表字段,是json中的流字段,所以需要在columns中增加字段描述
eg:
columns: id,name,age,f_time,u_time,is_delete,to_delete,__op=to_delete

to_delete的value是0或者1嘛?

表字段是哪些呢?