This is an automated email from the ASF dual-hosted git repository.
zouxinyi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 11735043d6 [improvement](test) logging load result (#14694)
11735043d6 is described below
commit 11735043d64438381163e1642898c1da369c7b7e
Author: Yongqiang YANG <[email protected]>
AuthorDate: Wed Nov 30 16:57:35 2022 +0800
[improvement](test) logging load result (#14694)
When a load failed, we have to login to doris to investigate result.
---
regression-test/suites/tpcds_sf100_p2/load.groovy | 3 ++-
regression-test/suites/tpch_sf100_p2/load.groovy | 1 +
regression-test/suites/tpch_sf100_unique_p2/load_four_step/load.groovy | 3 +++
regression-test/suites/tpch_sf100_unique_p2/load_one_step/load.groovy | 1 +
.../suites/tpch_sf100_unique_p2/load_three_step/load.groovy | 2 ++
regression-test/suites/tpch_sf100_unique_p2/load_two_step/load.groovy | 1 +
regression-test/suites/tpch_sf100_unique_sql_p2/load.groovy | 1 +
regression-test/suites/tpch_sf10_unique_p2/load_four_step/load.groovy | 3 +++
regression-test/suites/tpch_sf10_unique_p2/load_one_step/load.groovy | 1 +
regression-test/suites/tpch_sf10_unique_p2/load_three_step/load.groovy | 2 ++
regression-test/suites/tpch_sf10_unique_p2/load_two_step/load.groovy | 1 +
11 files changed, 18 insertions(+), 1 deletion(-)
diff --git a/regression-test/suites/tpcds_sf100_p2/load.groovy
b/regression-test/suites/tpcds_sf100_p2/load.groovy
index fa810215c2..24460ecd74 100644
--- a/regression-test/suites/tpcds_sf100_p2/load.groovy
+++ b/regression-test/suites/tpcds_sf100_p2/load.groovy
@@ -61,6 +61,7 @@ suite('load') {
// check load state
while (true) {
def stateResult = sql "show load where Label = '${loadLabel}'"
+ logger.info("load result ${stateResult}");
def loadState = stateResult[stateResult.size() -
1][2].toString()
if ('CANCELLED'.equalsIgnoreCase(loadState)) {
throw new IllegalStateException("load ${loadLabel}
failed.")
@@ -73,4 +74,4 @@ suite('load') {
}
assertEquals(rows, rowCount[0][0])
}
-}
\ No newline at end of file
+}
diff --git a/regression-test/suites/tpch_sf100_p2/load.groovy
b/regression-test/suites/tpch_sf100_p2/load.groovy
index 4585f19dc3..757c4a2dc2 100644
--- a/regression-test/suites/tpch_sf100_p2/load.groovy
+++ b/regression-test/suites/tpch_sf100_p2/load.groovy
@@ -57,6 +57,7 @@ suite("load") {
// check load state
while (true) {
def stateResult = sql "show load where Label = '${loadLabel}'"
+ logger.info("load result is ${stateResult}")
def loadState = stateResult[stateResult.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState)) {
throw new IllegalStateException("load ${loadLabel}
failed.")
diff --git
a/regression-test/suites/tpch_sf100_unique_p2/load_four_step/load.groovy
b/regression-test/suites/tpch_sf100_unique_p2/load_four_step/load.groovy
index 90a77e6c73..95880234e1 100644
--- a/regression-test/suites/tpch_sf100_unique_p2/load_four_step/load.groovy
+++ b/regression-test/suites/tpch_sf100_unique_p2/load_four_step/load.groovy
@@ -48,6 +48,7 @@ suite("load_four_step") {
// check load state
while (true) {
def stateResult1 = sql "show load where Label = '${loadLabel1}'"
+ logger.info("load result is ${stateResult1}")
def loadState1 = stateResult1[stateResult1.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState1)) {
throw new IllegalStateException("load ${loadLabel1} failed.")
@@ -65,6 +66,7 @@ suite("load_four_step") {
while (true) {
def stateResult2 = sql "show load where Label =
'${loadLabel2}'"
+ logger.info("load result is ${stateResult2}")
def loadState2 = stateResult2[stateResult2.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState2)) {
throw new IllegalStateException("load ${loadLabel2}
failed.")
@@ -95,6 +97,7 @@ suite("load_four_step") {
while (true) {
def stateResult3 = sql "show load where Label =
'${loadLabel3}'"
+ logger.info("load result is ${stateResult3}")
def loadState3 = stateResult3[stateResult3.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState3)) {
throw new IllegalStateException("load ${loadLabel3}
failed.")
diff --git
a/regression-test/suites/tpch_sf100_unique_p2/load_one_step/load.groovy
b/regression-test/suites/tpch_sf100_unique_p2/load_one_step/load.groovy
index 9804829dc0..4185d04b5a 100644
--- a/regression-test/suites/tpch_sf100_unique_p2/load_one_step/load.groovy
+++ b/regression-test/suites/tpch_sf100_unique_p2/load_one_step/load.groovy
@@ -46,6 +46,7 @@ suite("load_one_step") {
// check load state
while (true) {
def stateResult = sql "show load where Label = '${loadLabel}'"
+ logger.info("load result is ${stateResult}")
def loadState = stateResult[stateResult.size() - 1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState)) {
throw new IllegalStateException("load ${loadLabel} failed.")
diff --git
a/regression-test/suites/tpch_sf100_unique_p2/load_three_step/load.groovy
b/regression-test/suites/tpch_sf100_unique_p2/load_three_step/load.groovy
index e59e017449..5b476b127f 100644
--- a/regression-test/suites/tpch_sf100_unique_p2/load_three_step/load.groovy
+++ b/regression-test/suites/tpch_sf100_unique_p2/load_three_step/load.groovy
@@ -47,6 +47,7 @@ suite("load_three_step") {
// check load state
while (true) {
def stateResult1 = sql "show load where Label = '${loadLabel1}'"
+ logger.info("load result is ${stateResult1}")
def loadState1 = stateResult1[stateResult1.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState1)) {
throw new IllegalStateException("load ${loadLabel1} failed.")
@@ -64,6 +65,7 @@ suite("load_three_step") {
while (true) {
def stateResult2 = sql "show load where Label =
'${loadLabel2}'"
+ logger.info("load result is ${stateResult2}")
def loadState2 = stateResult2[stateResult2.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState2)) {
throw new IllegalStateException("load ${loadLabel2}
failed.")
diff --git
a/regression-test/suites/tpch_sf100_unique_p2/load_two_step/load.groovy
b/regression-test/suites/tpch_sf100_unique_p2/load_two_step/load.groovy
index fcf80d8794..d979ee99f2 100644
--- a/regression-test/suites/tpch_sf100_unique_p2/load_two_step/load.groovy
+++ b/regression-test/suites/tpch_sf100_unique_p2/load_two_step/load.groovy
@@ -47,6 +47,7 @@ suite("load_two_step") {
// check load state
while (true) {
def stateResult = sql "show load where Label = '${loadLabel}'"
+ logger.info("load result is ${stateResult}")
def loadState = stateResult[stateResult.size() - 1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState)) {
throw new IllegalStateException("load ${loadLabel} failed.")
diff --git a/regression-test/suites/tpch_sf100_unique_sql_p2/load.groovy
b/regression-test/suites/tpch_sf100_unique_sql_p2/load.groovy
index 4585f19dc3..757c4a2dc2 100644
--- a/regression-test/suites/tpch_sf100_unique_sql_p2/load.groovy
+++ b/regression-test/suites/tpch_sf100_unique_sql_p2/load.groovy
@@ -57,6 +57,7 @@ suite("load") {
// check load state
while (true) {
def stateResult = sql "show load where Label = '${loadLabel}'"
+ logger.info("load result is ${stateResult}")
def loadState = stateResult[stateResult.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState)) {
throw new IllegalStateException("load ${loadLabel}
failed.")
diff --git
a/regression-test/suites/tpch_sf10_unique_p2/load_four_step/load.groovy
b/regression-test/suites/tpch_sf10_unique_p2/load_four_step/load.groovy
index 716bdc6dbc..d1ebfc5f19 100644
--- a/regression-test/suites/tpch_sf10_unique_p2/load_four_step/load.groovy
+++ b/regression-test/suites/tpch_sf10_unique_p2/load_four_step/load.groovy
@@ -48,6 +48,7 @@ suite("load_four_step") {
// check load state
while (true) {
def stateResult1 = sql "show load where Label =
'${loadLabel1}'"
+ logger.info("load result ${stateResult1}");
def loadState1 = stateResult1[stateResult1.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState1)) {
throw new IllegalStateException("load ${loadLabel1}
failed.")
@@ -65,6 +66,7 @@ suite("load_four_step") {
while(true){
def stateResult2 = sql "show load where Label =
'${loadLabel2}'"
+ logger.info("load result ${stateResult2}");
def loadState2 = stateResult2[stateResult2.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState2)) {
throw new IllegalStateException("load
${loadLabel2} failed.")
@@ -94,6 +96,7 @@ suite("load_four_step") {
while(true){
def stateResult3 = sql "show load where Label =
'${loadLabel3}'"
+ logger.info("load result ${stateResult3}");
def loadState3 = stateResult3[stateResult3.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState3)) {
throw new IllegalStateException("load
${loadLabel3} failed.")
diff --git
a/regression-test/suites/tpch_sf10_unique_p2/load_one_step/load.groovy
b/regression-test/suites/tpch_sf10_unique_p2/load_one_step/load.groovy
index c7b4c94223..0db6495aad 100644
--- a/regression-test/suites/tpch_sf10_unique_p2/load_one_step/load.groovy
+++ b/regression-test/suites/tpch_sf10_unique_p2/load_one_step/load.groovy
@@ -46,6 +46,7 @@ suite("load_one_step") {
// check load state
while (true) {
def stateResult = sql "show load where Label = '${loadLabel}'"
+ logger.info("load result ${stateResult}");
def loadState = stateResult[stateResult.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState)) {
throw new IllegalStateException("load ${loadLabel}
failed.")
diff --git
a/regression-test/suites/tpch_sf10_unique_p2/load_three_step/load.groovy
b/regression-test/suites/tpch_sf10_unique_p2/load_three_step/load.groovy
index 2fa9cd2829..1771b87ec3 100644
--- a/regression-test/suites/tpch_sf10_unique_p2/load_three_step/load.groovy
+++ b/regression-test/suites/tpch_sf10_unique_p2/load_three_step/load.groovy
@@ -47,6 +47,7 @@ suite("load_three_step") {
// check load state
while (true) {
def stateResult1 = sql "show load where Label =
'${loadLabel1}'"
+ logger.info("load result ${stateResult1}");
def loadState1 = stateResult1[stateResult1.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState1)) {
throw new IllegalStateException("load ${loadLabel1}
failed.")
@@ -64,6 +65,7 @@ suite("load_three_step") {
while(true){
def stateResult2 = sql "show load where Label =
'${loadLabel2}'"
+ logger.info("load result ${stateResult2}");
def loadState2 = stateResult2[stateResult2.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState2)) {
throw new IllegalStateException("load
${loadLabel2} failed.")
diff --git
a/regression-test/suites/tpch_sf10_unique_p2/load_two_step/load.groovy
b/regression-test/suites/tpch_sf10_unique_p2/load_two_step/load.groovy
index f0deb2c66d..93f765d4a6 100644
--- a/regression-test/suites/tpch_sf10_unique_p2/load_two_step/load.groovy
+++ b/regression-test/suites/tpch_sf10_unique_p2/load_two_step/load.groovy
@@ -47,6 +47,7 @@ suite("load_two_step") {
// check load state
while (true) {
def stateResult = sql "show load where Label = '${loadLabel}'"
+ logger.info("load result is ${stateResult}")
def loadState = stateResult[stateResult.size() -
1][2].toString()
if ("CANCELLED".equalsIgnoreCase(loadState)) {
throw new IllegalStateException("load ${loadLabel}
failed.")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
