Skip to content

Commit

Permalink
branch-3.0: [opt](test) Make the case stable #44910 (#45007)
Browse files Browse the repository at this point in the history
Cherry-picked from #44910

Co-authored-by: Sun Chenyang <[email protected]>
  • Loading branch information
github-actions[bot] and csun5285 authored Dec 11, 2024
1 parent 112bbb8 commit 635aa6c
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

import org.codehaus.groovy.runtime.IOGroovyMethods

suite("test_index_compaction_dup_keys_array", "array_contains_inverted_index") {
suite("test_index_compaction_dup_keys_array", "array_contains_inverted_index, nonConcurrent") {
// here some variable to control inverted index query
sql """ set enable_profile=true"""
sql """ set enable_pipeline_x_engine=true;"""
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

import org.codehaus.groovy.runtime.IOGroovyMethods

suite("test_index_compaction_null_arr", "array_contains_inverted_index") {
suite("test_index_compaction_null_arr", "array_contains_inverted_index, nonConcurrent") {
// here some variable to control inverted index query
sql """ set enable_profile=true"""
sql """ set enable_pipeline_x_engine=true;"""
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

import org.codehaus.groovy.runtime.IOGroovyMethods

suite("test_index_compaction_unique_keys_arr", "array_contains_inverted_index") {
suite("test_index_compaction_unique_keys_arr", "array_contains_inverted_index, nonConcurrent") {
// here some variable to control inverted index query
sql """ set enable_profile=true"""
sql """ set enable_pipeline_x_engine=true;"""
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ import java.util.concurrent.Executors
import java.util.concurrent.TimeUnit
import org.awaitility.Awaitility

suite("test_index_compaction_empty_segments", "p0") {
suite("test_index_compaction_empty_segments", "p0, nonConcurrent") {

def compaction_table_name = "test_index_compaction_empty_segments"
def backendId_to_backendIP = [:]
Expand Down Expand Up @@ -82,8 +82,9 @@ suite("test_index_compaction_empty_segments", "p0") {
});
}

int afterSegmentCount = 0

for (def tablet in tablets) {
int afterSegmentCount = 0
String tablet_id = tablet.TabletId
(code, out, err) = curl("GET", tablet.CompactionStatus)
logger.info("Show tablets status: code=" + code + ", out=" + out + ", err=" + err)
Expand All @@ -94,6 +95,6 @@ suite("test_index_compaction_empty_segments", "p0") {
logger.info("rowset is: " + rowset)
afterSegmentCount += Integer.parseInt(rowset.split(" ")[1])
}
assertEquals(afterSegmentCount, 0)
}
assertEquals(afterSegmentCount, 0)
}

0 comments on commit 635aa6c

Please sign in to comment.