wait data propagate

risingwavelabs · Mar 7, 2024 · ed4712f · ed4712f
1 parent a217e46
commit ed4712f
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/e2e_test/schema_registry/alter_sr.slt b/e2e_test/schema_registry/alter_sr.slt
@@ -38,6 +38,8 @@ SELECT age FROM t_user;
 system ok
 python3 e2e_test/schema_registry/pb.py "message_queue:29092" "http://message_queue:8081" "sr_pb_test" 5 user_with_more_fields
 
+sleep 5s
+
 # Refresh source schema
 statement ok
 ALTER SOURCE src_user FORMAT PLAIN ENCODE PROTOBUF(
@@ -61,6 +63,8 @@ SELECT COUNT(*), MAX(age), MIN(age), SUM(age) FROM mv_user_more;
 system ok
 python3 e2e_test/schema_registry/pb.py "message_queue:29092" "http://message_queue:8081" "sr_pb_test" 5 user_with_more_fields
 
+sleep 5s
+
 query IIII
 SELECT COUNT(*), MAX(age), MIN(age), SUM(age) FROM t_user;
 ----