Skip to content

Flink 1.13: Fix flaky testHashDistributeMode by ingesting all rows in one checkpoint cycle - #4213

Merged
openinx merged 1 commit into
apache:masterfrom
openinx:flink-1.13-fix-flakey-testHashDistributionMode
Feb 25, 2022
Merged

Flink 1.13: Fix flaky testHashDistributeMode by ingesting all rows in one checkpoint cycle#4213
openinx merged 1 commit into
apache:masterfrom
openinx:flink-1.13-fix-flakey-testHashDistributionMode

Conversation

@openinx

Copy link
Copy Markdown
Member

Port #4189 to flink 1.13.

Reference issue: #2575

@openinx

Copy link
Copy Markdown
MemberAuthor

Executed 20 times to validate the correctness:

./gradlew :iceberg-flink:iceberg-flink-1.13_2.12:test --tests "org.apache.iceberg.flink.TestFlinkTableSink" -DflinkVersions=1.13

@kbendickkbendick left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

+1 LGTM

@openinx

Copy link
Copy Markdown
MemberAuthor

Thanks @kbendick for the check. As we've got +1 from apache iceberg committers in the original PR, plan to get this merged for stability test.

@openinx
openinx merged commit 7ced339 into apache:masterFeb 25, 2022
@openinx
openinx deleted the flink-1.13-fix-flakey-testHashDistributionMode branch February 25, 2022 01:31
Sign up for freeto join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants

@openinx@kbendick