[FLINK-11179][tests] add wait time for every record for testCancelSor…

[sunjincheng121]

What is the purpose of the change

(test case bug fix: add wait time for every record for testCancelSortMatchWhileDoingHeavySorting.)

Brief change log

• add wait time for every record for testCancelSortMatchWhileDoingHeavySorting

Verifying this change

This change is a test case bug fix.

Does this pull request potentially affect one of the following parts:

• Dependencies (does it add or upgrade a dependency): (no)
• The public API, i.e., is any changed class annotated with @Public(Evolving): ( no)
• The serializers: (no)
• The runtime per-record code paths (performance sensitive): (no)
• Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: ( no )
• The S3 file system connector: ( no)

Documentation

• Does this pull request introduce a new feature? (no)

[hequn8128]

@sunjincheng121 Thanks for reporting and fixing the problem. The test can pass with the fix. As for the changes, how about make delay configurable in DelayingMatcher? Keep SimpleMatcher as what it is, i.e, keep it simple.

Best, Hequn

[sunjincheng121]

Hi Thanks for the review @hequn8128 !
If we using DelayingMatcher then we do not need this test case anymore. So I think both add the wait_time and make delayingMatcher are can not achieve the purpose of testing。 Because wait_time and delayingMatcher only test the join phase，we want test the sore-merge phase. So we should make sore-merge phase take more time to achieve the purpose of testing. I got a better approach，and will update the PR.

[sunjincheng121]

Hi @hequn8128 I had update the PR. appreciate if you can look at it again!
Thanks,
Jincheng

[hequn8128]

@sunjincheng121 Thanks for the update. The code is good. +1 to merge from my side.
Best, Hequj

[sunjincheng121]

Thanks @hequn8128, will be merged as soon as CI passed.