rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-08-18 12:08:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: enlarge fuzz failover test timeout waiting for datanodes online (#8633)

Browse Source 
* chore: enlarge fuzz test timeout while waiting Kafka cluster

Signed-off-by: Lei, HUANG <ratuthomm@gmail.com>

* ci: extend Kafka readiness timeout

Signed-off-by: Lei, HUANG <ratuthomm@gmail.com>

---------

Signed-off-by: Lei, HUANG <ratuthomm@gmail.com>
This commit is contained in:
Lei, HUANG
2026-07-24 18:40:03 +08:00
committed by GitHub
parent d39f2292fa
commit abf9fbf6ea
4 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.github/scripts/wait-kafka-ready.sh
+1 -1
View File
@@ -6,7 +6,7 @@ GT_KAFKA_NAMESPACE="${GT_KAFKA_NAMESPACE:-kafka-cluster}"
GT_KAFKA_CLIENT_NAMESPACE="${GT_KAFKA_CLIENT_NAMESPACE:-my-greptimedb}"
GT_KAFKA_BOOTSTRAP_SERVERS="${GT_KAFKA_BOOTSTRAP_SERVERS:-kafka.kafka-cluster.svc.cluster.local:9092}"
GT_KAFKA_IMAGE="${GT_KAFKA_IMAGE:-docker.io/greptime/kafka:3.9.0-debian-12-r1}"
GT_KAFKA_READY_TIMEOUT_SECS="${GT_KAFKA_READY_TIMEOUT_SECS:-120}"
GT_KAFKA_READY_TIMEOUT_SECS="${GT_KAFKA_READY_TIMEOUT_SECS:-180}"
GT_KAFKA_READY_INTERVAL_SECS="${GT_KAFKA_READY_INTERVAL_SECS:-5}"
GT_KAFKA_POD_LABEL="${GT_KAFKA_POD_LABEL:-app.kubernetes.io/instance=kafka}"
.github/workflows/develop.yml
+2 -2
View File
@@ -443,7 +443,7 @@ jobs:
kubectl wait \
--for=condition=Ready \
pod -l app.kubernetes.io/instance=kafka \
--timeout=120s \
--timeout=180s \
-n kafka-cluster
- if: matrix.mode.kafkaWalHelper
name: Setup Kafka WAL helper
@@ -653,7 +653,7 @@ jobs:
kubectl wait \
--for=condition=Ready \
pod -l app.kubernetes.io/instance=kafka \
--timeout=120s \
--timeout=180s \
-n kafka-cluster
- name: Print etcd info
shell: bash
tests-fuzz/targets/failover/fuzz_failover_metric_regions.rs
+1 -1
View File
@@ -252,7 +252,7 @@ async fn execute_failover(ctx: FuzzContext, input: FuzzInput) -> Result<()> {
// Recovers pod failures
recover_pod_failure(ctx.kube.clone(), &ctx.namespace, &chaos_name).await?;
wait_for_all_datanode_online(ctx.greptime.clone(), Duration::from_secs(60)).await;
wait_for_all_datanode_online(ctx.greptime.clone(), Duration::from_secs(180)).await;
tokio::time::sleep(default_distributed_time_constants().region_lease).await;
// Validates value rows
tests-fuzz/targets/failover/fuzz_failover_mito_regions.rs
+1 -1
View File
@@ -320,7 +320,7 @@ async fn execute_failover(ctx: FuzzContext, input: FuzzInput) -> Result<()> {
// Recovers pod failures
recover_pod_failure(ctx.kube.clone(), &ctx.namespace, &chaos_name).await?;
wait_for_all_datanode_online(ctx.greptime.clone(), Duration::from_secs(60)).await;
wait_for_all_datanode_online(ctx.greptime.clone(), Duration::from_secs(180)).await;
tokio::time::sleep(default_distributed_time_constants().region_lease).await;
// Validates value rows