Skip to content
This repository has been archived by the owner on Dec 14, 2022. It is now read-only.

[BUG] Test failure for UpsertPulsarTableITCase#testAggregate #468

Open
syhily opened this issue Nov 19, 2021 · 2 comments · May be fixed by #479
Open

[BUG] Test failure for UpsertPulsarTableITCase#testAggregate #468

syhily opened this issue Nov 19, 2021 · 2 comments · May be fixed by #479
Assignees
@jianyun8023
Labels
compute/data-processing type/bug

Comments

@syhily
Copy link
Contributor

syhily commented Nov 19, 2021

Describe the bug

The testAggregate fails on the current master branch.
@jianyun8023
Copy link
Contributor

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
Copy link
Contributor

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

@jianyun8023 jianyun8023 linked a pull request Dec 3, 2021 that will close this issue
Open
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees

@jianyun8023 jianyun8023

Labels
compute/data-processing type/bug
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

fix expected data for UpsertPulsarTableITCase jianyun8023/pulsar-flink
2 participants
@syhily @jianyun8023