这个是行列分隔符选择有问题,建议可以配置为json写入
.withProperty("sink.properties.format", "json")
.withProperty("sink.properties.strip_outer_array", "true")
这个是行列分隔符选择有问题,建议可以配置为json写入
.withProperty("sink.properties.format", "json")
.withProperty("sink.properties.strip_outer_array", "true")
当前sink的配置也可以发下
看起来是原始数据中有特殊字符,最下面那两个改成下面json导入
‘sink.properties.format’=‘json’,
sink.properties.strip_outer_array’=‘true’