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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
