diff --git a/regression-test/suites/export/test_array_export.groovy b/regression-test/suites/export/test_array_export.groovy index 0301e92f6d0f84..82240951067fe6 100644 --- a/regression-test/suites/export/test_array_export.groovy +++ b/regression-test/suites/export/test_array_export.groovy @@ -118,10 +118,11 @@ suite("test_array_export", "export") { } def select_out_file = {exportTable, HdfsPath, outFormat, BrokerName, HdfsUserName, HdfsPasswd-> - sql """ + + def sqlString = """ SELECT * FROM ${exportTable} INTO OUTFILE "${HdfsPath}" - FORMAT AS "${outFormat}" + FORMAT AS ${outFormat} PROPERTIES ( "broker.name" = "${BrokerName}", @@ -131,6 +132,8 @@ suite("test_array_export", "export") { "broker.password"="${HdfsPasswd}" ) """ + logger.info("sqlString: ${sqlString}") + sql sqlString } def check_export_result = {checklabel-> diff --git a/regression-test/suites/load_p0/broker_load/test_array_load.groovy b/regression-test/suites/load_p0/broker_load/test_array_load.groovy index d88ce754ef4136..754c7ef9f2a088 100644 --- a/regression-test/suites/load_p0/broker_load/test_array_load.groovy +++ b/regression-test/suites/load_p0/broker_load/test_array_load.groovy @@ -173,7 +173,7 @@ suite("test_array_load", "load_p0") { def check_load_result = {checklabel, testTablex -> def max_try_milli_secs = 10000 while(max_try_milli_secs) { - result = sql "show load where label = '${checklabel}'" + def result = sql "show load where label = '${checklabel}'" if(result[0][2] == "FINISHED") { sql "sync" qt_select "select * from ${testTablex} order by k1" diff --git a/regression-test/suites/load_p0/broker_load/test_broker_load_seq.groovy b/regression-test/suites/load_p0/broker_load/test_broker_load_seq.groovy index 6faae220810034..b270b8266e9adf 100644 --- a/regression-test/suites/load_p0/broker_load/test_broker_load_seq.groovy +++ b/regression-test/suites/load_p0/broker_load/test_broker_load_seq.groovy @@ -77,7 +77,7 @@ suite("test_broker_load_seq", "load_p0") { def check_load_result = {checklabel, testTablex -> def max_try_milli_secs = 10000 while(max_try_milli_secs) { - result = sql "show load where label = '${checklabel}'" + def result = sql "show load where label = '${checklabel}'" if(result[0][2] == "FINISHED") { //sql "sync" qt_select "select * from ${testTablex} order by user_id, date, group_id" diff --git a/regression-test/suites/load_p0/broker_load/test_broker_load_with_merge.groovy b/regression-test/suites/load_p0/broker_load/test_broker_load_with_merge.groovy index 24bdee9761342a..1816e6d49850d8 100644 --- a/regression-test/suites/load_p0/broker_load/test_broker_load_with_merge.groovy +++ b/regression-test/suites/load_p0/broker_load/test_broker_load_with_merge.groovy @@ -26,7 +26,7 @@ suite("test_broker_load_with_merge", "load_p0") { `k2` DATE NOT NULL, `k3` INT(11) NOT NULL, `k4` INT(11) NOT NULL, - `v5` BIGINT SUM NULL DEFAULT "0" + `v5` BIGINT NULL DEFAULT "0" ) ENGINE=OLAP UNIQUE KEY(`k1`) COMMENT 'OLAP' diff --git a/regression-test/suites/load_p0/broker_load/test_broker_load_with_partition.groovy b/regression-test/suites/load_p0/broker_load/test_broker_load_with_partition.groovy index 0324d4c8f6e824..8a677259f919fd 100644 --- a/regression-test/suites/load_p0/broker_load/test_broker_load_with_partition.groovy +++ b/regression-test/suites/load_p0/broker_load/test_broker_load_with_partition.groovy @@ -110,7 +110,7 @@ suite("test_broker_load_with_partition", "load_p0") { def check_load_result = {checklabel, testTablex -> def max_try_milli_secs = 10000 while(max_try_milli_secs) { - result = sql "show load where label = '${checklabel}'" + def result = sql "show load where label = '${checklabel}'" log.info("result: ${result}") if(result[0][2] == "FINISHED") { //sql "sync" @@ -129,7 +129,7 @@ suite("test_broker_load_with_partition", "load_p0") { def check_load_tmp_partition_result = {checklabel, testTablex -> max_try_milli_secs = 10000 while(max_try_milli_secs) { - result = sql "show load where label = '${checklabel}'" + def result = sql "show load where label = '${checklabel}'" log.info("result: ${result}") if(result[0][2] == "FINISHED") { //sql "sync" diff --git a/regression-test/suites/load_p0/broker_load/test_broker_load_with_where.groovy b/regression-test/suites/load_p0/broker_load/test_broker_load_with_where.groovy index a058f10349ec9c..08d72a54b537f2 100644 --- a/regression-test/suites/load_p0/broker_load/test_broker_load_with_where.groovy +++ b/regression-test/suites/load_p0/broker_load/test_broker_load_with_where.groovy @@ -101,7 +101,7 @@ suite("test_broker_load_with_where", "load_p0") { def check_load_result = {checklabel, testTablex -> def max_try_milli_secs = 10000 while(max_try_milli_secs) { - result = sql "show load where label = '${checklabel}'" + def result = sql "show load where label = '${checklabel}'" if(result[0][2] == "FINISHED") { //sql "sync" qt_select "select * from ${testTablex} order by k1" diff --git a/regression-test/suites/load_p0/stream_load/test_json_load.groovy b/regression-test/suites/load_p0/stream_load/test_json_load.groovy index 172fd9fe7a972b..2fdd8e724c10f0 100644 --- a/regression-test/suites/load_p0/stream_load/test_json_load.groovy +++ b/regression-test/suites/load_p0/stream_load/test_json_load.groovy @@ -228,7 +228,7 @@ suite("test_json_load", "p0,nonConcurrent") { } def check_load_result = {checklabel, testTablex -> - def max_try_milli_secs = 10000 + def max_try_milli_secs = 100000 while(max_try_milli_secs) { def result = sql "show load where label = '${checklabel}'" if(result[0][2] == "FINISHED") {