Iceberg upsert:

当iceberg中同一批插入主键相同的多条数据,flink sql 查询不出来,会报错。报错如下:
java.lang.IllegalArgumentException: Row arity: 3, but serializer arity: 2

这个错误的意思就是,我插入的数据是两列,但是table schema已经是三列了。
大家知道这是什么问题么?

当主键不同的时候,同一批插入多条数据都是可以正常插入,并且也是可以upsert的。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复