Skip to content

[FLINK-36656][mysql] Fix type conversion failure for newly-added sharding table with mysql boolean type#3684

Merged
ruanhang1993 merged 1 commit into
apache:release-3.2from
leonardBang:backport_Flink-36656
Nov 20, 2024
Merged

[FLINK-36656][mysql] Fix type conversion failure for newly-added sharding table with mysql boolean type#3684
ruanhang1993 merged 1 commit into
apache:release-3.2from
leonardBang:backport_Flink-36656

Conversation

@leonardBang

Copy link
Copy Markdown
Contributor

backport PR for release-3.2 branch


private static void waitForSinkSize(String sinkName, int expectedSize)
throws InterruptedException {
while (sinkSize(sinkName) < expectedSize) {

Copy link
Copy Markdown

Choose a reason for hiding this comment

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

I am concerned that if sinkSize(sinkName) is incorrectly less than expectedSize then we have an infinite loop.

I suggest having a time out on the while loop to ensure they complete in failure conditions after say 30 seconds.

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

Nice catch and will adjust later, but as it's an existed method thus I tend to improve the tests infra in later PR, HDYT?

@ruanhang1993 ruanhang1993 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.

LGTM

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants