Flink: fix flaky testTwoSinksInDisjointedDAG that may stuck#3514

Merged

rdblue merged 1 commit intoapache:masterfrom

stevenzwu:issue-3112

Nov 14, 2021

Commits on Nov 9, 2021

Flink: switch from BoundedTestSource to simple fromCollection for TestFlinkIcebergSink#testTwoSinksInDisjointedDAG. The purpose of this test method is that we can constrcut two Iceberg sinks in the…
stevenzwu
committed