From b11dcce61a3763d8b738f763cbe67bc35efe85fe Mon Sep 17 00:00:00 2001
From: airborne12 <jiangkai@selectdb.com>
Date: Wed, 13 Nov 2024 14:14:16 +0800
Subject: [PATCH] [Fix](test) add sync to bloom filter test case (#43840)

Problem Summary:
try to fix bloomfilter case fail by adding sync command
---
 .../bloom_filter_p0/test_bloom_filter_drop_column.groovy       | 3 +++
 .../test_bloom_filter_hit_with_renamed_column.groovy           | 2 ++
 2 files changed, 5 insertions(+)

diff --git a/regression-test/suites/bloom_filter_p0/test_bloom_filter_drop_column.groovy b/regression-test/suites/bloom_filter_p0/test_bloom_filter_drop_column.groovy
index a18ff9fdbe0d80..fcf6103677510b 100644
--- a/regression-test/suites/bloom_filter_p0/test_bloom_filter_drop_column.groovy
+++ b/regression-test/suites/bloom_filter_p0/test_bloom_filter_drop_column.groovy
@@ -33,11 +33,13 @@ suite("test_bloom_filter_drop_column") {
     )"""
 
     sql """INSERT INTO ${table_name} values ('1', '1')"""
+    sql "sync"
 
     qt_select """select * from ${table_name} order by a"""
 
     // drop column c1
     sql """ALTER TABLE ${table_name} DROP COLUMN c1"""
+    sql "sync"
     // show create table
     def res = sql """SHOW CREATE TABLE ${table_name}"""
     assert res[0][1].contains("\"bloom_filter_columns\" = \"\"")
@@ -46,6 +48,7 @@ suite("test_bloom_filter_drop_column") {
     sql """ALTER TABLE ${table_name} ADD COLUMN c1 ARRAY<STRING>"""
     // insert data
     sql """INSERT INTO ${table_name} values ('2', null)"""
+    sql "sync"
     // select data
     qt_select """select * from ${table_name} order by a"""
 }
diff --git a/regression-test/suites/bloom_filter_p0/test_bloom_filter_hit_with_renamed_column.groovy b/regression-test/suites/bloom_filter_p0/test_bloom_filter_hit_with_renamed_column.groovy
index 059d7c95445c0f..ef45cd88b92260 100644
--- a/regression-test/suites/bloom_filter_p0/test_bloom_filter_hit_with_renamed_column.groovy
+++ b/regression-test/suites/bloom_filter_p0/test_bloom_filter_hit_with_renamed_column.groovy
@@ -112,6 +112,7 @@ suite("test_bloom_filter_hit_with_renamed_column") {
 
     sql """ SET enable_profile = true """
     sql """ set parallel_scan_min_rows_per_scanner = 2097152; """
+    sql "sync"
     //sql """ select C_COMMENT_NEW from ${tableName} where C_COMMENT_NEW='OK' """
 
     // get and check profile with retry logic
@@ -122,6 +123,7 @@ suite("test_bloom_filter_hit_with_renamed_column") {
         int attempt = 0
 
         while (attempt < maxRetries) {
+            sql "sync"
             sql """ ${query} """
             profiles = httpGet(profileUrl)
             log.info("profiles attempt ${attempt + 1}: {}", profiles)