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/
