This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new b7478f1f4f9 HDDS-15786. Intermittent pipeline limit exceeded in debug
tests (#10738)
b7478f1f4f9 is described below
commit b7478f1f4f94f3bb073de641c636afb4d88dac2b
Author: Doroszlai, Attila <[email protected]>
AuthorDate: Mon Jul 13 16:38:10 2026 +0200
HDDS-15786. Intermittent pipeline limit exceeded in debug tests (#10738)
---
hadoop-ozone/dist/src/main/compose/common/replicas-test.sh | 2 ++
hadoop-ozone/dist/src/main/compose/testlib.sh | 13 +++++++++++++
2 files changed, 15 insertions(+)
diff --git a/hadoop-ozone/dist/src/main/compose/common/replicas-test.sh
b/hadoop-ozone/dist/src/main/compose/common/replicas-test.sh
index 31cc0c1f9b6..964957b21ea 100755
--- a/hadoop-ozone/dist/src/main/compose/common/replicas-test.sh
+++ b/hadoop-ozone/dist/src/main/compose/common/replicas-test.sh
@@ -66,6 +66,8 @@ for dn_container in ${datanodes}; do
wait_for_datanode "${dn_container}" HEALTHY 60
done
+wait_for_pipeline
+
execute_robot_test ${SCM} -v "PREFIX:${prefix}" debug/ozone-debug-tests.robot
# get block locations for key
diff --git a/hadoop-ozone/dist/src/main/compose/testlib.sh
b/hadoop-ozone/dist/src/main/compose/testlib.sh
index 210b4bbf385..a9aedeed208 100755
--- a/hadoop-ozone/dist/src/main/compose/testlib.sh
+++ b/hadoop-ozone/dist/src/main/compose/testlib.sh
@@ -126,6 +126,19 @@ wait_for_safemode_exit(){
execute_commands_in_container ${SCM} "$cmd"
}
+## @description wait until RATIS/THREE pipeline exists (or 180 seconds)
+wait_for_pipeline() {
+ RETRY_ATTEMPTS=60 retry assert_pipeline_exists
+}
+
+## @description check if RATIS/THREE pipeline exists; note: does not kinit
+assert_pipeline_exists() {
+ local cmd="ozone admin pipeline list --state OPEN --filter-by-factor THREE
--json | jq -r 'length'"
+ local -i count
+ count=$(execute_commands_in_container ${SCM} "${cmd}")
+ [[ $count -gt 0 ]]
+}
+
## @description wait until OM leader is elected (or 120 seconds)
wait_for_om_leader() {
if [[ -z "${OM_SERVICE_ID:-}" ]]; then
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
