[BUG] Test failure for UpsertPulsarTableITCase#testAggregate
syhily opened this issue · 2 comments
syhily commented
Describe the bug
The testAggregate fails on the current master branch.
jianyun8023 commented
The expected value is changed to +[2,1] and that works. The reason is that Flink version upgrade added RowKind field for Row to mark this data as inserted, deleted, etc. flink issue https://issues.apache.org/jira/browse/FLINK-16998
jianyun8023 commented
In the test, often use Row or RowData toString() method to compare, Row.toString() method to add this rowKind field occurred in flink version 1.13