kingwind94 opened a new issue, #5858: URL: https://github.com/apache/iceberg/issues/5858
### Apache Iceberg version 0.13.1 ### Query engine Flink ### Please describe the bug 🐞 I'm using version 1.14.5 for my flink cluster, and the 1.14 iceberg-flink connector is 1.14.0. I thought it is not a big deal to upgrade 1.14.0 to 1.14.5 (acutually bugs happened after 1.14.3). It turned out that iceber-flink confused the Rowkind of rowdata and it gained a wrong result. Expected :[Record(1, aaa), Record(2, ccc), Record(2, aaa), Record(1, ccc)] Actual :[Record(1, aaa), Record(2, bbb), Record(2, ccc), Record(2, aaa), Record(1, bbb, 1, false), Record(1, ccc)] I tried to discovery which flink modules affect the result, but could not find it. Some APIs are changed, totally a mess. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
