Iceberg upsert:

当iceberg中同一批插入多条主键值相同的数据的时候,通过flink sql进行查询,数据查询不到,并且会报如下的错误:

java.lang.IllegalArgumentException: Row arity: 3, but serializer arity: 2

这个报错的意思是:原本的数据是两列,表的schema也是两列,但是现在schema已经变成了三列了

大家有见过这个报错或问题么?

但是当主键不同时候,同一批插入多条数据,是可以进行正常查询的,并且也是可以upsert的



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

回复