你指的是用json format么?这个是json format的问题,当前的确是会把所有字段都写进去,不管是否为null。

我们内部也有类似需求,我们是修改了json format,可以允许忽略null的列。

<abc15...@163.com> 于2020年8月23日周日 下午6:11写道:

> 在flink1.11中使用table sql写入时,有一些字段为空时,依然被写入到elasticsearch,这个方式应该不太恰当。
>
>
>

-- 

Best,
Benchao Li

回复