[FLINK-19936] Make SinkITCase stable

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.12.0
• Fix Version/s: 1.12.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Guowei Ma
• Reporter: Guowei Ma
• Created: 03/Nov/20 04:40
• Updated: 06/Nov/20 02:42
• Resolved: 04/Nov/20 18:03

Description

In the streaming execution mode there are two uncertain things:

1. The order of receiving the checkpoint complete.(`Committer` receive first or `GlobalCommitter` receive first)
2. Whether the operator can receive the last checkpoint

 This patch does following two things to resolve `SinkITCase`'s unstable owning to these two uncertainty 

1. Changing how to verifying the output of `GlobalCommitter` for the case 1
2. Let the `FiniteTestSource` exit only when the Committer/GlobalCommitter received all the elements.

 

 

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=8815&view=logs&j=5c8e7682-d68f-54d1-16a2-a09310218a49&t=f508e270-48d6-5f1e-3138-42a17e0714f0 

Issue Links

• duplicates: FLINK-20010 SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on Azure Pipeline
• links to: GitHub Pull Request #13898
• links to: GitHub Pull Request #13898