hf200012 commented on issue #5557:
URL:
https://github.com/apache/incubator-doris/issues/5557#issuecomment-810104982
> > Reason: actual column number is less than schema column number. actual
number: 1 sep: , schema number: 4; . src line:
[{"data":[{"id":"26","name":"222","status":"22","date":"0000-00-00"}],"database":"test","es":1616467578000,"id":7,"isDdl":false,"mysqlType":{"id":"bigint(20)","name":"varchar(45)","status":"varchar(45)","date":"date"},"old":null,"pkNames":["id"],"sql":"","sqlType":{"id":-5,"name":12,"status":12,"date":91},"table":"canal_test","ts":1616467578825,"type":"INSERT"}];
>
> u can use flink to preprocess your json data, and write into a new topic,
then use Routine load to consume data.
>
> 你可以用flink预处理下json数据，处理成doris认识的数据格式，然后写进一个新topic，再使用doris的Routine load导入
After flink processing, directly use stream load to table
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
