database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[regression test](stream load) load_to_single_tablet (#26720)

Browse Source
This commit is contained in:
Guangdong Liu
2023-11-10 10:20:24 +08:00
committed by GitHub
parent 7754791146
commit 76c0a906e5
1 changed files with 31 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
View File

@ -375,6 +375,37 @@ suite("test_stream_load_properties", "p0") {
sql new File("""${context.file.parent}/ddl/dup_tbl_basic_drop_random_bucket.sql""").text
}
try {
sql new File("""${context.file.parent}/ddl/dup_tbl_basic_drop_random_bucket.sql""").text
sql new File("""${context.file.parent}/ddl/dup_tbl_basic_create_random_bucket.sql""").text
streamLoad {
table 'stream_load_dup_tbl_basic_random_bucket'
set 'column_separator', '|'
set 'columns', columns[0]
set 'load_to_single_tablet', 'false'
file files[0]
time 10000 // limit inflight 10s
check { result, exception, startTime, endTime ->
if (exception != null) {
throw exception
}
log.info("Stream load result: ${result}".toString())
def json = parseJson(result)
assertEquals("success", json.Status.toLowerCase())
assertEquals(20, json.NumberTotalRows)
assertEquals(20, json.NumberLoadedRows)
assertEquals(0, json.NumberFilteredRows)
assertEquals(0, json.NumberUnselectedRows)
}
}
// def res = sql "show tablets from stream_load_dup_tbl_basic_random_bucket"
// assertEquals(res[0][10].toString(), "20")
} finally {
sql new File("""${context.file.parent}/ddl/dup_tbl_basic_drop_random_bucket.sql""").text
}
// sequence
try {
sql new File("""${context.file.parent}/ddl/uniq_tbl_basic_drop_sequence.sql""").text