This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 64a79cc03a4 [bugfix](testcase)add java error log output for 2.1
(#37128)
64a79cc03a4 is described below
commit 64a79cc03a42fec410c80822ba09e024e0d5016c
Author: wuwenchi <[email protected]>
AuthorDate: Tue Jul 2 22:53:38 2024 +0800
[bugfix](testcase)add java error log output for 2.1 (#37128)
pick #35998
---
.../suites/connector_p0/spark_connector/spark_connector.groovy | 10 ++++++++--
.../connector_p0/spark_connector/spark_connector_arrow.groovy | 10 ++++++++--
.../spark_connector/spark_connector_read_type.groovy | 10 ++++++++--
3 files changed, 24 insertions(+), 6 deletions(-)
diff --git
a/regression-test/suites/connector_p0/spark_connector/spark_connector.groovy
b/regression-test/suites/connector_p0/spark_connector/spark_connector.groovy
index ecd4e6dfc14..2bd618fcc3c 100644
--- a/regression-test/suites/connector_p0/spark_connector/spark_connector.groovy
+++ b/regression-test/suites/connector_p0/spark_connector/spark_connector.groovy
@@ -28,7 +28,13 @@ suite("spark_connector", "connector") {
logger.info("finish download spark doris demo ...")
def run_cmd = "java -jar spark-doris-demo.jar
$context.config.feHttpAddress $context.config.feHttpUser
regression_test_connector_p0_spark_connector.$tableName"
logger.info("run_cmd : $run_cmd")
- def run_spark_jar = run_cmd.execute().getText()
- logger.info("result: $run_spark_jar")
+ def proc = run_cmd.execute()
+ def sout = new StringBuilder()
+ def serr = new StringBuilder()
+ proc.consumeProcessOutput(sout, serr)
+ proc.waitForOrKill(1200_000)
+ if (proc.exitValue() != 0) {
+ logger.warn("failed to execute jar: code=${proc.exitValue()}, " +
"output: ${sout.toString()}, error: ${serr.toString()}")
+ }
qt_select """ select * from $tableName order by order_id"""
}
diff --git
a/regression-test/suites/connector_p0/spark_connector/spark_connector_arrow.groovy
b/regression-test/suites/connector_p0/spark_connector/spark_connector_arrow.groovy
index 1cd2ed31d2e..a5fbc3b2835 100644
---
a/regression-test/suites/connector_p0/spark_connector/spark_connector_arrow.groovy
+++
b/regression-test/suites/connector_p0/spark_connector/spark_connector_arrow.groovy
@@ -136,8 +136,14 @@ suite("spark_connector_for_arrow", "connector") {
logger.info("finish download spark doris demo ...")
def run_cmd = "java -cp ${jar_name}
org.apache.doris.spark.testcase.TestStreamLoadForArrowType
$context.config.feHttpAddress $context.config.feHttpUser
regression_test_connector_p0_spark_connector"
logger.info("run_cmd : $run_cmd")
- def run_spark_jar = run_cmd.execute().getText()
- logger.info("result: $run_spark_jar")
+ def proc = run_cmd.execute()
+ def sout = new StringBuilder()
+ def serr = new StringBuilder()
+ proc.consumeProcessOutput(sout, serr)
+ proc.waitForOrKill(1200_000)
+ if (proc.exitValue() != 0) {
+ logger.warn("failed to execute jar: code=${proc.exitValue()}, " +
"output: ${sout.toString()}, error: ${serr.toString()}")
+ }
qt_q01 """ select * from spark_connector_primitive """
qt_q02 """ select * from spark_connector_array """
diff --git
a/regression-test/suites/connector_p0/spark_connector/spark_connector_read_type.groovy
b/regression-test/suites/connector_p0/spark_connector/spark_connector_read_type.groovy
index 32a3ebf68c7..632e5e3d401 100644
---
a/regression-test/suites/connector_p0/spark_connector/spark_connector_read_type.groovy
+++
b/regression-test/suites/connector_p0/spark_connector/spark_connector_read_type.groovy
@@ -99,8 +99,14 @@ suite("spark_connector_read_type", "connector") {
logger.info("finish download spark doris demo ...")
def run_cmd = "java -jar spark-doris-read.jar
$context.config.feHttpAddress $context.config.feHttpUser
regression_test_connector_p0_spark_connector.$tableReadName
regression_test_connector_p0_spark_connector.$tableWriterName"
logger.info("run_cmd : $run_cmd")
- def run_spark_jar = run_cmd.execute().getText()
- logger.info("result: $run_spark_jar")
+ def proc = run_cmd.execute()
+ def sout = new StringBuilder()
+ def serr = new StringBuilder()
+ proc.consumeProcessOutput(sout, serr)
+ proc.waitForOrKill(1200_000)
+ if (proc.exitValue() != 0) {
+ logger.warn("failed to execute jar: code=${proc.exitValue()}, " +
"output: ${sout.toString()}, error: ${serr.toString()}")
+ }
qt_select """ select * from $tableWriterName order by id"""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
