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)