yuxiqian commented on code in PR #3227: URL: https://github.com/apache/flink-cdc/pull/3227#discussion_r1575921082
########## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/utils/DorisSinkTestBase.java: ########## @@ -156,9 +156,10 @@ public static boolean checkBackendAvailability() { if (rs.getExitCode() != 0) { return false; } - LOG.info("Doris backend status:\n{}", rs.getStdout()); - return rs.getStdout() - .contains("*************************** 1. row ***************************"); + String output = rs.getStdout(); + LOG.info("Doris backend status:\n{}", output); + return output.contains("*************************** 1. row ***************************") + && !output.contains("AvailCapacity: 1.000 B"); Review Comment: There's a Doris startup stage where `SHOW BACKENDS;` outputs rows while its available disk capacity is zero. ``` *************************** 1. row *************************** BackendId: 10004 Host: 127.0.0.1 Alive: true (...) TabletNum: 0 DataUsedCapacity: 0.000 TrashUsedCapcacity: 0.000 AvailCapacity: 1.000 B TotalCapacity: 0.000 (...) ``` Though backend declares itself as "alive", any DDL operations will fail due to a no-disk-available error. Explicitly waiting for disk to initialize fixes this problem. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org