From ed4712f6885903a70cc623396b5ef79c3678df8f Mon Sep 17 00:00:00 2001
From: Rossil <40714231+Rossil2012@users.noreply.github.com>
Date: Thu, 7 Mar 2024 19:06:44 +0800
Subject: [PATCH] wait data propagate

---
 e2e_test/schema_registry/alter_sr.slt | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/e2e_test/schema_registry/alter_sr.slt b/e2e_test/schema_registry/alter_sr.slt
index 79551f2e971a7..0ba9ae9da5541 100644
--- 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;
 ----