Flink: Backport #9078 to v1.16 and v1.15

[cgpoh]

Backport gh-9078 to v1.16 and v1.15

[pvary]

Thanks for the backports @cgpoh!
Please when doing backport next time, tell the reviewers if it was a clean backport, or you had to change anything. This would help with the reviews!

@cgpoh: If you have time, affinity, it would be nice if you could move the other junit4 tests to junit5 too? I will be here to review them in timely manner 😄

Thanks,
Peter

[cgpoh]

Hi @pvary, thanks for the review. Just to clarify, is this PR consider clean backport?

I will try my best to move the junit 4 tests to 5 😃

[pvary]

Hi @pvary, thanks for the review. Just to clarify, is this PR consider clean backport?

If you just have to apply the Flink v1.17 changes to the v1.16, v1.15 folder, and you do not need to change anything then it is a clean backport. If you need to do some changes, because the old Flink version does not support some feature needed by the change, then it is not a clean backport

I generate the backport patches like this:

git diff HEAD^ |sed -e "s/v1.17/v1.15/g" > 1.15.patch

I will try my best to move the junit 4 tests to 5 😃

There are plenty of Flink tests which still uses junit4, so we will have tasks for a long while 😄

Thanks,
Peter