你指的是用json format么?这个是json format的问题,当前的确是会把所有字段都写进去,不管是否为null。
我们内部也有类似需求,我们是修改了json format,可以允许忽略null的列。 <abc15...@163.com> 于2020年8月23日周日 下午6:11写道: > 在flink1.11中使用table sql写入时,有一些字段为空时,依然被写入到elasticsearch,这个方式应该不太恰当。 > > > -- Best, Benchao Li
你指的是用json format么?这个是json format的问题,当前的确是会把所有字段都写进去,不管是否为null。
我们内部也有类似需求,我们是修改了json format,可以允许忽略null的列。 <abc15...@163.com> 于2020年8月23日周日 下午6:11写道: > 在flink1.11中使用table sql写入时,有一些字段为空时,依然被写入到elasticsearch,这个方式应该不太恰当。 > > > -- Best, Benchao Li