diff --git a/tests-fuzz/targets/failover/fuzz_failover_metric_regions.rs b/tests-fuzz/targets/failover/fuzz_failover_metric_regions.rs index 5eaf43ab0a8e..147c3ead1e41 100644 --- a/tests-fuzz/targets/failover/fuzz_failover_metric_regions.rs +++ b/tests-fuzz/targets/failover/fuzz_failover_metric_regions.rs @@ -257,7 +257,12 @@ async fn execute_failover(ctx: FuzzContext, input: FuzzInput) -> Result<()> { for (table_ctx, insert_expr) in tables.values() { let sql = format!("select count(1) as count from {}", table_ctx.name); let values = count_values(&ctx.greptime, &sql).await?; - assert_eq!(values.count as usize, insert_expr.values_list.len()); + let expected_rows = insert_expr.values_list.len() as u64; + assert_eq!( + values.count as u64, expected_rows, + "Expected rows: {}, got: {}, table: {}", + expected_rows, values.count, table_ctx.name + ); } // Clean up diff --git a/tests-fuzz/targets/failover/fuzz_failover_mito_regions.rs b/tests-fuzz/targets/failover/fuzz_failover_mito_regions.rs index 5fab5f260333..f456550b3fb9 100644 --- a/tests-fuzz/targets/failover/fuzz_failover_mito_regions.rs +++ b/tests-fuzz/targets/failover/fuzz_failover_mito_regions.rs @@ -323,7 +323,11 @@ async fn execute_failover(ctx: FuzzContext, input: FuzzInput) -> Result<()> { for (table_ctx, expected_rows) in table_ctxs.iter().zip(affected_rows) { let sql = format!("select count(1) as count from {}", table_ctx.name); let values = count_values(&ctx.greptime, &sql).await?; - assert_eq!(values.count as u64, expected_rows); + assert_eq!( + values.count as u64, expected_rows, + "Expected rows: {}, got: {}, table: {}", + expected_rows, values.count, table_ctx.name + ); } for table_ctx in table_ctxs {