[fix](test) fix unstable pk uk case (#23390)
This commit is contained in:
@ -227,9 +227,11 @@ suite("test_pk_uk_index_change", "inverted_index") {
|
||||
wait_for_build_index_on_partition_finish(tableNamePk, timeout)
|
||||
}
|
||||
|
||||
sql "sync"
|
||||
|
||||
// count(*)
|
||||
result0 = sql """ SELECT count(*) FROM ${tableNamePk}; """
|
||||
result1 = sql """ SELECT count(*) FROM ${tableNameUk}; """
|
||||
def result0 = sql """ SELECT count(*) FROM ${tableNamePk}; """
|
||||
def result1 = sql """ SELECT count(*) FROM ${tableNameUk}; """
|
||||
logger.info("result:" + result0[0][0] + "|" + result1[0][0])
|
||||
assertTrue(result0[0]==result1[0])
|
||||
if (result0[0][0]!=result1[0][0]) {
|
||||
|
||||
@ -191,9 +191,11 @@ suite("test_pk_uk_case", "inverted_index") {
|
||||
($order_key, $part_key, $sub_key, $line_num, $decimal, $decimal, $decimal, $decimal, '1', '1', '$date', '$date', '$date', '$name', '$name', '$city')
|
||||
"""
|
||||
|
||||
sql "sync"
|
||||
|
||||
// count(*)
|
||||
result0 = sql """ SELECT count(*) FROM ${tableNamePk}; """
|
||||
result1 = sql """ SELECT count(*) FROM ${tableNameUk}; """
|
||||
def result0 = sql """ SELECT count(*) FROM ${tableNamePk}; """
|
||||
def result1 = sql """ SELECT count(*) FROM ${tableNameUk}; """
|
||||
logger.info("result:" + result0[0][0] + "|" + result1[0][0])
|
||||
assertTrue(result0[0]==result1[0])
|
||||
if (result0[0][0]!=result1[0][0]) {
|
||||
|
||||
@ -187,8 +187,8 @@ suite("test_pk_uk_case") {
|
||||
sql "sync"
|
||||
|
||||
// count(*)
|
||||
result0 = sql """ SELECT count(*) FROM ${tableNamePk}; """
|
||||
result1 = sql """ SELECT count(*) FROM ${tableNameUk}; """
|
||||
def result0 = sql """ SELECT count(*) FROM ${tableNamePk}; """
|
||||
def result1 = sql """ SELECT count(*) FROM ${tableNameUk}; """
|
||||
logger.info("result:" + result0[0][0] + "|" + result1[0][0])
|
||||
assertTrue(result0[0]==result1[0])
|
||||
if (result0[0][0]!=result1[0][0]) {
|
||||
|
||||
@ -187,8 +187,8 @@ suite("test_pk_uk_case") {
|
||||
sql "sync"
|
||||
|
||||
// count(*)
|
||||
result0 = sql """ SELECT count(*) FROM ${tableNamePk}; """
|
||||
result1 = sql """ SELECT count(*) FROM ${tableNameUk}; """
|
||||
def result0 = sql """ SELECT count(*) FROM ${tableNamePk}; """
|
||||
def result1 = sql """ SELECT count(*) FROM ${tableNameUk}; """
|
||||
logger.info("result:" + result0[0][0] + "|" + result1[0][0])
|
||||
assertTrue(result0[0]==result1[0])
|
||||
if (result0[0][0]!=result1[0][0]) {
|
||||
|
||||
Reference in New Issue
Block a user