Skip to content

Commit

Permalink
[Fix](test) add sync to bloom filter test case (#43840)
Browse files Browse the repository at this point in the history
### What problem does this PR solve?

Problem Summary:
try to fix bloomfilter case fail by adding sync command
  • Loading branch information
airborne12 authored Nov 13, 2024
1 parent 47dab4d commit ecfb3d0
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -74,22 +74,26 @@ 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"""
wait_for_latest_op_on_table_finish(table_name, timeout)
sql "sync"

// show create table with retry logic
assertShowCreateTableWithRetry(table_name, "\"bloom_filter_columns\" = \"\"", 3, 30)

// add new column c1
sql """ALTER TABLE ${table_name} ADD COLUMN c1 ARRAY<STRING>"""
wait_for_latest_op_on_table_finish(table_name, timeout)
sql "sync"

// insert data
sql """INSERT INTO ${table_name} values ('2', null)"""
sql "sync"
// select data
qt_select """select * from ${table_name} order by a"""
}
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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)
Expand Down

0 comments on commit ecfb3d0

Please sign in to comment.