Yanquan Lv created FLINK-37349:
----------------------------------
Summary: Add timeout for test case that call waitForSinkSize
method to avoid Infinite waiting
Key: FLINK-37349
URL: https://issues.apache.org/jira/browse/FLINK-37349
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.3.0
Reporter: Yanquan Lv
Fix For: cdc-3.4.0
Add timeout for test case that call waitForSinkSize method:
{code:java}
protected static void waitForSinkSize(String sinkName, int expectedSize)
throws InterruptedException {
while (sinkSize(sinkName) < expectedSize) {
Thread.sleep(100);
}
} {code}
In abnormal case, this will lead to infinite waiting until CI time out.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
