From e68100e87235e18a6fdf9eb979ee98cbd1d0ac6b Mon Sep 17 00:00:00 2001 From: yujun777 Date: Tue, 30 Jan 2024 18:33:16 +0800 Subject: [PATCH] update regression --- .../stream_load/test_map_load_and_compaction.groovy | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy b/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy index 4a3b99c1d06f2d..4a80004169b46f 100644 --- a/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy +++ b/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy @@ -98,10 +98,10 @@ suite("test_map_load_and_compaction", "p0") { // check here 2 rowsets //TabletId,ReplicaId,BackendId,SchemaHash,Version,LstSuccessVersion,LstFailedVersion,LstFailedTime,LocalDataSize,RemoteDataSize,RowCount,State,LstConsistencyCheckTime,CheckVersion,VersionCount,PathHash,MetaUrl,CompactionStatus - String[][] tablets = sql """ show tablets from ${testTable}; """ - String[] tablet = tablets[0] + def tablets = sql_return_maparray """ show tablets from ${testTable}; """ + def tablet = tablets[0] // check rowsets number - String compactionStatus = tablet[18] + String compactionStatus = tablet.CompactionStatus checkCompactionStatus.call(compactionStatus, 6) // trigger compaction @@ -109,8 +109,8 @@ suite("test_map_load_and_compaction", "p0") { def backendId_to_backendIP = [:] def backendId_to_backendHttpPort = [:] getBackendIpHttpPort(backendId_to_backendIP, backendId_to_backendHttpPort); - String tablet_id = tablet[0] - backend_id = tablet[2] + String tablet_id = tablet.TabletId + backend_id = tablet.BackendId def (code, out, err) = be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id), backendId_to_backendHttpPort.get(backend_id), tablet_id) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) assertEquals(code, 0)