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)

Reply via email to