全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

kafka 中字段为空字符串""时，导致flink sql 写 doris 字段错位如何解决？

提问者：帅平问题分类：大数据

Doris Flink FlinkSql Kafka

发布于：4个月前 (12-30) IP属地：

1 个回答

流年似水べ梦未央

可以改为json格式导入，sink.properties 加：

properties.setProperty("format", "json");
properties.setProperty("read_json_by_line", "true");

发布于：4个月前 (12-30) IP属地：

我来回答