diff --git a/regression-test/suites/cloud_p0/schema_change/compaction1/test_schema_change_with_compaction1.groovy b/regression-test/suites/cloud_p0/schema_change/compaction1/test_schema_change_with_compaction1.groovy index ed78edd6ca8661..64b03d8cb6683e 100644 --- a/regression-test/suites/cloud_p0/schema_change/compaction1/test_schema_change_with_compaction1.groovy +++ b/regression-test/suites/cloud_p0/schema_change/compaction1/test_schema_change_with_compaction1.groovy @@ -29,6 +29,7 @@ import org.apache.doris.regression.util.NodeType suite('test_schema_change_with_compaction1', 'nonConcurrent') { def getJobState = { tableName -> def jobStateResult = sql """ SHOW ALTER TABLE COLUMN WHERE IndexName='${tableName}' ORDER BY createtime DESC LIMIT 1 """ + logger.info("jobStateResult: " + jobStateResult) return jobStateResult[0][9] } @@ -57,6 +58,7 @@ suite('test_schema_change_with_compaction1', 'nonConcurrent') { // check load state while (true) { def stateResult = sql "show load where Label = '${loadLabel}'" + logger.info("stateResult: " + stateResult) def loadState = stateResult[stateResult.size() - 1][2].toString() if ("CANCELLED".equalsIgnoreCase(loadState)) { throw new IllegalStateException("load ${loadLabel} failed.") @@ -107,13 +109,15 @@ suite('test_schema_change_with_compaction1', 'nonConcurrent') { trigger_and_wait_compaction("date", "base") def newTabletId = array[1].TabletId logger.info("run compaction:" + newTabletId) - (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, newTabletId) + def (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, newTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("invalid tablet state.")) // cu compaction trigger_and_wait_compaction("date", "cumulative") + } catch (Exception e) { + logger.error("Exception: " + e) } finally { if (injectBe != null) { DebugPoint.disableDebugPoint(injectBe.Host, injectBe.HttpPort.toInteger(), NodeType.BE, injectName) @@ -136,7 +140,7 @@ suite('test_schema_change_with_compaction1', 'nonConcurrent') { assertEquals(count[0][0], 23004); // check rowsets logger.info("run show:" + originTabletId) - (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run show: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("[0-1]")) assertTrue(out.contains("[2-7]")) diff --git a/regression-test/suites/cloud_p0/schema_change/compaction10/test_schema_change_with_compaction10.groovy b/regression-test/suites/cloud_p0/schema_change/compaction10/test_schema_change_with_compaction10.groovy index b7b6bd4e433d87..2e9ad0628d4d53 100644 --- a/regression-test/suites/cloud_p0/schema_change/compaction10/test_schema_change_with_compaction10.groovy +++ b/regression-test/suites/cloud_p0/schema_change/compaction10/test_schema_change_with_compaction10.groovy @@ -60,6 +60,7 @@ suite('test_schema_change_with_compaction10', 'docker') { // check load state while (true) { def stateResult = sql "show load where Label = '${loadLabel}'" + logger.info("stateResult: " + stateResult) def loadState = stateResult[stateResult.size() - 1][2].toString() if ("CANCELLED".equalsIgnoreCase(loadState)) { throw new IllegalStateException("load ${loadLabel} failed.") @@ -113,12 +114,14 @@ suite('test_schema_change_with_compaction10', 'docker') { trigger_and_wait_compaction("date", "base") def newTabletId = array[1].TabletId logger.info("run compaction:" + newTabletId) - (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, newTabletId) + def (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, newTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("invalid tablet state.")) // cu compaction trigger_and_wait_compaction("date", "cumulative") + } catch (Exception e) { + logger.error("Exception: " + e) } finally { if (injectBe != null) { GetDebugPoint().disableDebugPointForAllBEs(injectName) @@ -141,7 +144,7 @@ suite('test_schema_change_with_compaction10', 'docker') { assertEquals(count[0][0], 2556); // check rowsets logger.info("run show:" + originTabletId) - (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run show: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("[0-1]")) assertTrue(out.contains("[2-7]")) diff --git a/regression-test/suites/cloud_p0/schema_change/compaction2/test_schema_change_with_compaction2.groovy b/regression-test/suites/cloud_p0/schema_change/compaction2/test_schema_change_with_compaction2.groovy index c8ca8a54109824..667a498d6c0ad3 100644 --- a/regression-test/suites/cloud_p0/schema_change/compaction2/test_schema_change_with_compaction2.groovy +++ b/regression-test/suites/cloud_p0/schema_change/compaction2/test_schema_change_with_compaction2.groovy @@ -29,6 +29,7 @@ import org.apache.doris.regression.util.NodeType suite('test_schema_change_with_compaction2', 'nonConcurrent') { def getJobState = { tableName -> def jobStateResult = sql """ SHOW ALTER TABLE COLUMN WHERE IndexName='${tableName}' ORDER BY createtime DESC LIMIT 1 """ + logger.info("jobStateResult: " + jobStateResult) return jobStateResult[0][9] } @@ -57,6 +58,7 @@ suite('test_schema_change_with_compaction2', 'nonConcurrent') { // check load state while (true) { def stateResult = sql "show load where Label = '${loadLabel}'" + logger.info("stateResult: " + stateResult) def loadState = stateResult[stateResult.size() - 1][2].toString() if ("CANCELLED".equalsIgnoreCase(loadState)) { throw new IllegalStateException("load ${loadLabel} failed.") @@ -83,7 +85,7 @@ suite('test_schema_change_with_compaction2', 'nonConcurrent') { sql "select count(*) from date" // cu compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) boolean running = true do { @@ -113,7 +115,7 @@ suite('test_schema_change_with_compaction2', 'nonConcurrent') { // base compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) @@ -134,6 +136,8 @@ suite('test_schema_change_with_compaction2', 'nonConcurrent') { logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("invalid tablet state.")) + } catch (Exception e) { + logger.error("Exception: " + e) } finally { if (injectBe != null) { DebugPoint.disableDebugPoint(injectBe.Host, injectBe.HttpPort.toInteger(), NodeType.BE, injectName) @@ -158,7 +162,7 @@ suite('test_schema_change_with_compaction2', 'nonConcurrent') { assertEquals(count[0][0], 20448); // check rowsets logger.info("run show:" + originTabletId) - (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run show: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("[0-1]")) assertTrue(out.contains("[2-7]")) diff --git a/regression-test/suites/cloud_p0/schema_change/compaction3/test_schema_change_with_compaction3.groovy b/regression-test/suites/cloud_p0/schema_change/compaction3/test_schema_change_with_compaction3.groovy index b2aab9f2dc7c84..cf59823cb784dd 100644 --- a/regression-test/suites/cloud_p0/schema_change/compaction3/test_schema_change_with_compaction3.groovy +++ b/regression-test/suites/cloud_p0/schema_change/compaction3/test_schema_change_with_compaction3.groovy @@ -29,6 +29,7 @@ import org.apache.doris.regression.util.NodeType suite('test_schema_change_with_compaction3', 'nonConcurrent') { def getJobState = { tableName -> def jobStateResult = sql """ SHOW ALTER TABLE COLUMN WHERE IndexName='${tableName}' ORDER BY createtime DESC LIMIT 1 """ + logger.info("jobStateResult: " + jobStateResult) return jobStateResult[0][9] } @@ -57,6 +58,7 @@ suite('test_schema_change_with_compaction3', 'nonConcurrent') { // check load state while (true) { def stateResult = sql "show load where Label = '${loadLabel}'" + logger.info("stateResult: " + stateResult) def loadState = stateResult[stateResult.size() - 1][2].toString() if ("CANCELLED".equalsIgnoreCase(loadState)) { throw new IllegalStateException("load ${loadLabel} failed.") @@ -83,7 +85,7 @@ suite('test_schema_change_with_compaction3', 'nonConcurrent') { sql "select count(*) from date" // cu compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) boolean running = true do { @@ -117,7 +119,7 @@ suite('test_schema_change_with_compaction3', 'nonConcurrent') { // base compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) @@ -160,6 +162,8 @@ suite('test_schema_change_with_compaction3', 'nonConcurrent') { running = compactionStatus.run_status } while (running) } + } catch (Exception e) { + logger.error("Exception: " + e) } finally { sql """ CANCEL ALTER TABLE COLUMN FROM date """ if (injectBe != null) { @@ -183,7 +187,7 @@ suite('test_schema_change_with_compaction3', 'nonConcurrent') { assertEquals(count[0][0], 23004); // check rowsets logger.info("run show:" + originTabletId) - (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run show: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("[0-1]")) assertTrue(out.contains("[2-7]")) diff --git a/regression-test/suites/cloud_p0/schema_change/compaction4/test_schema_change_with_compaction4.groovy b/regression-test/suites/cloud_p0/schema_change/compaction4/test_schema_change_with_compaction4.groovy index 4b53dbdd998104..a57e32bf922f64 100644 --- a/regression-test/suites/cloud_p0/schema_change/compaction4/test_schema_change_with_compaction4.groovy +++ b/regression-test/suites/cloud_p0/schema_change/compaction4/test_schema_change_with_compaction4.groovy @@ -29,6 +29,7 @@ import org.apache.doris.regression.util.NodeType suite('test_schema_change_with_compaction4', 'nonConcurrent') { def getJobState = { tableName -> def jobStateResult = sql """ SHOW ALTER TABLE MATERIALIZED VIEW WHERE IndexName='${tableName}' ORDER BY createtime DESC LIMIT 1 """ + logger.info("jobStateResult: " + jobStateResult) return jobStateResult[0][8] } @@ -57,6 +58,7 @@ suite('test_schema_change_with_compaction4', 'nonConcurrent') { // check load state while (true) { def stateResult = sql "show load where Label = '${loadLabel}'" + logger.info("stateResult: " + stateResult) def loadState = stateResult[stateResult.size() - 1][2].toString() if ("CANCELLED".equalsIgnoreCase(loadState)) { throw new IllegalStateException("load ${loadLabel} failed.") @@ -83,7 +85,7 @@ suite('test_schema_change_with_compaction4', 'nonConcurrent') { sql "select count(*) from date" // cu compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) boolean running = true do { @@ -117,7 +119,7 @@ suite('test_schema_change_with_compaction4', 'nonConcurrent') { // base compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) @@ -160,6 +162,8 @@ suite('test_schema_change_with_compaction4', 'nonConcurrent') { running = compactionStatus.run_status } while (running) } + } catch (Exception e) { + logger.error("Exception: " + e) } finally { sql """ CANCEL ALTER TABLE MATERIALIZED VIEW FROM date """ if (injectBe != null) { @@ -183,7 +187,7 @@ suite('test_schema_change_with_compaction4', 'nonConcurrent') { assertEquals(count[0][0], 23004); // check rowsets logger.info("run show:" + originTabletId) - (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run show: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("[0-1]")) assertTrue(out.contains("[2-7]")) diff --git a/regression-test/suites/cloud_p0/schema_change/compaction5/test_schema_change_with_compaction5.groovy b/regression-test/suites/cloud_p0/schema_change/compaction5/test_schema_change_with_compaction5.groovy index 094b8a53737231..8af620ea6479b4 100644 --- a/regression-test/suites/cloud_p0/schema_change/compaction5/test_schema_change_with_compaction5.groovy +++ b/regression-test/suites/cloud_p0/schema_change/compaction5/test_schema_change_with_compaction5.groovy @@ -60,6 +60,7 @@ suite('test_schema_change_with_compaction5', 'docker') { // check load state while (true) { def stateResult = sql "show load where Label = '${loadLabel}'" + logger.info("stateResult: " + stateResult) def loadState = stateResult[stateResult.size() - 1][2].toString() if ("CANCELLED".equalsIgnoreCase(loadState)) { throw new IllegalStateException("load ${loadLabel} failed.") @@ -86,7 +87,7 @@ suite('test_schema_change_with_compaction5', 'docker') { sql "select count(*) from date" // cu compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) boolean running = true do { @@ -118,7 +119,7 @@ suite('test_schema_change_with_compaction5', 'docker') { } // base compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) @@ -164,6 +165,8 @@ suite('test_schema_change_with_compaction5', 'docker') { cluster.restartFrontends() sleep(30000) context.reconnectFe() + } catch (Exception e) { + logger.error("Exception: " + e) } finally { if (injectBe != null) { GetDebugPoint().disableDebugPointForAllBEs(injectName) @@ -186,7 +189,7 @@ suite('test_schema_change_with_compaction5', 'docker') { assertEquals(count[0][0], 23004); // check rowsets logger.info("run show:" + originTabletId) - (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run show: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("[0-1]")) assertTrue(out.contains("[2-7]")) diff --git a/regression-test/suites/cloud_p0/schema_change/compaction6/test_schema_change_with_compaction6.groovy b/regression-test/suites/cloud_p0/schema_change/compaction6/test_schema_change_with_compaction6.groovy index d2ac4f14cd9158..4321a23f7b7fb3 100644 --- a/regression-test/suites/cloud_p0/schema_change/compaction6/test_schema_change_with_compaction6.groovy +++ b/regression-test/suites/cloud_p0/schema_change/compaction6/test_schema_change_with_compaction6.groovy @@ -60,6 +60,7 @@ suite('test_schema_change_with_compaction6', 'docker') { // check load state while (true) { def stateResult = sql "show load where Label = '${loadLabel}'" + logger.info("stateResult: " + stateResult) def loadState = stateResult[stateResult.size() - 1][2].toString() if ("CANCELLED".equalsIgnoreCase(loadState)) { throw new IllegalStateException("load ${loadLabel} failed.") @@ -86,7 +87,7 @@ suite('test_schema_change_with_compaction6', 'docker') { sql "select count(*) from date" // cu compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) boolean running = true do { @@ -167,6 +168,8 @@ suite('test_schema_change_with_compaction6', 'docker') { } while (running) } + } catch (Exception e) { + logger.error("Exception: " + e) } finally { if (injectBe != null) { GetDebugPoint().disableDebugPointForAllBEs(injectName) @@ -189,7 +192,7 @@ suite('test_schema_change_with_compaction6', 'docker') { assertEquals(count[0][0], 23004); // check rowsets logger.info("run show:" + originTabletId) - (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run show: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("[0-1]")) assertTrue(out.contains("[2-7]")) diff --git a/regression-test/suites/cloud_p0/schema_change/compaction7/test_schema_change_with_compaction7.groovy b/regression-test/suites/cloud_p0/schema_change/compaction7/test_schema_change_with_compaction7.groovy index 7291ea3a341e44..a43de53c4720ce 100644 --- a/regression-test/suites/cloud_p0/schema_change/compaction7/test_schema_change_with_compaction7.groovy +++ b/regression-test/suites/cloud_p0/schema_change/compaction7/test_schema_change_with_compaction7.groovy @@ -29,6 +29,7 @@ import org.apache.doris.regression.util.NodeType suite('test_schema_change_with_compaction7', 'nonConcurrent') { def getJobState = { tableName -> def jobStateResult = sql """ SHOW ALTER TABLE COLUMN WHERE IndexName='${tableName}' ORDER BY createtime DESC LIMIT 1 """ + logger.info("jobStateResult: " + jobStateResult) return jobStateResult[0][9] } @@ -57,6 +58,7 @@ suite('test_schema_change_with_compaction7', 'nonConcurrent') { // check load state while (true) { def stateResult = sql "show load where Label = '${loadLabel}'" + logger.info("stateResult: " + stateResult) def loadState = stateResult[stateResult.size() - 1][2].toString() if ("CANCELLED".equalsIgnoreCase(loadState)) { throw new IllegalStateException("load ${loadLabel} failed.") @@ -83,7 +85,7 @@ suite('test_schema_change_with_compaction7', 'nonConcurrent') { sql "select count(*) from date" // cu compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) boolean running = true do { @@ -116,7 +118,7 @@ suite('test_schema_change_with_compaction7', 'nonConcurrent') { } // base compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) @@ -159,6 +161,8 @@ suite('test_schema_change_with_compaction7', 'nonConcurrent') { running = compactionStatus.run_status } while (running) } + } catch (Exception e) { + logger.error("Exception: " + e) } finally { if (injectBe != null) { DebugPoint.disableDebugPoint(injectBe.Host, injectBe.HttpPort.toInteger(), NodeType.BE, injectName) @@ -181,7 +185,7 @@ suite('test_schema_change_with_compaction7', 'nonConcurrent') { assertEquals(count[0][0], 2556); // check rowsets logger.info("run show:" + originTabletId) - (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run show: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("[0-1]")) assertTrue(out.contains("[2-7]")) diff --git a/regression-test/suites/cloud_p0/schema_change/compaction8/test_schema_change_with_compaction8.groovy b/regression-test/suites/cloud_p0/schema_change/compaction8/test_schema_change_with_compaction8.groovy index 1017e1d50f235f..3002cb9c2273b4 100644 --- a/regression-test/suites/cloud_p0/schema_change/compaction8/test_schema_change_with_compaction8.groovy +++ b/regression-test/suites/cloud_p0/schema_change/compaction8/test_schema_change_with_compaction8.groovy @@ -29,6 +29,7 @@ import org.apache.doris.regression.util.NodeType suite('test_schema_change_with_compaction8', 'nonConcurrent') { def getJobState = { tableName -> def jobStateResult = sql """ SHOW ALTER TABLE COLUMN WHERE IndexName='${tableName}' ORDER BY createtime DESC LIMIT 1 """ + logger.info("jobStateResult: " + jobStateResult) return jobStateResult[0][9] } @@ -57,6 +58,7 @@ suite('test_schema_change_with_compaction8', 'nonConcurrent') { // check load state while (true) { def stateResult = sql "show load where Label = '${loadLabel}'" + logger.info("stateResult: " + stateResult) def loadState = stateResult[stateResult.size() - 1][2].toString() if ("CANCELLED".equalsIgnoreCase(loadState)) { throw new IllegalStateException("load ${loadLabel} failed.") @@ -83,7 +85,7 @@ suite('test_schema_change_with_compaction8', 'nonConcurrent') { sql "select count(*) from date" // cu compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) boolean running = true do { @@ -113,7 +115,7 @@ suite('test_schema_change_with_compaction8', 'nonConcurrent') { // base compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) @@ -134,6 +136,8 @@ suite('test_schema_change_with_compaction8', 'nonConcurrent') { logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("invalid tablet state.")) + } catch (Exception e) { + logger.error("Exception: " + e) } finally { if (injectBe != null) { DebugPoint.disableDebugPoint(injectBe.Host, injectBe.HttpPort.toInteger(), NodeType.BE, injectName) @@ -158,7 +162,7 @@ suite('test_schema_change_with_compaction8', 'nonConcurrent') { assertEquals(count[0][0], 2556); // check rowsets logger.info("run show:" + originTabletId) - (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run show: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("[0-1]")) assertTrue(out.contains("[2-7]")) diff --git a/regression-test/suites/cloud_p0/schema_change/compaction9/test_schema_change_with_compaction9.groovy b/regression-test/suites/cloud_p0/schema_change/compaction9/test_schema_change_with_compaction9.groovy index 316b10283b1df6..ad33e537d4920b 100644 --- a/regression-test/suites/cloud_p0/schema_change/compaction9/test_schema_change_with_compaction9.groovy +++ b/regression-test/suites/cloud_p0/schema_change/compaction9/test_schema_change_with_compaction9.groovy @@ -88,7 +88,7 @@ suite('test_schema_change_with_compaction9', 'docker') { sql "select count(*) from date" // cu compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_cumulative_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) boolean running = true do { @@ -120,7 +120,7 @@ suite('test_schema_change_with_compaction9', 'docker') { } // base compaction logger.info("run compaction:" + originTabletId) - (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_run_base_compaction(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run compaction: code=" + code + ", out=" + out + ", err=" + err) @@ -191,7 +191,7 @@ suite('test_schema_change_with_compaction9', 'docker') { assertEquals(count[0][0], 2556); // check rowsets logger.info("run show:" + originTabletId) - (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) + def (code, out, err) = be_show_tablet_status(injectBe.Host, injectBe.HttpPort, originTabletId) logger.info("Run show: code=" + code + ", out=" + out + ", err=" + err) assertTrue(out.contains("[0-1]")) assertTrue(out.contains("[2-7]"))