From b0835b43365d3ce415777c5518c03384f1432cfd Mon Sep 17 00:00:00 2001
From: Xin Liao <liaoxinbit@126.com>
Date: Thu, 8 Feb 2024 11:45:17 +0800
Subject: [PATCH] [fix](test) Increase the timeout duration for the test case
 (#30952)

---
 .../data/datatype_p0/decimalv3/test.csv       |  3 ++
 .../datatype_p0/decimalv3/test_load.groovy    | 31 ++++++++++---------
 2 files changed, 20 insertions(+), 14 deletions(-)
 create mode 100644 regression-test/data/datatype_p0/decimalv3/test.csv

diff --git a/regression-test/data/datatype_p0/decimalv3/test.csv b/regression-test/data/datatype_p0/decimalv3/test.csv
new file mode 100644
index 0000000000..667fe01c08
--- /dev/null
+++ b/regression-test/data/datatype_p0/decimalv3/test.csv
@@ -0,0 +1,3 @@
+0.00013225356500247968
+0.00039016009826936000
+0.00013503989119010048
diff --git a/regression-test/suites/datatype_p0/decimalv3/test_load.groovy b/regression-test/suites/datatype_p0/decimalv3/test_load.groovy
index 48cfb286f4..c1a6a944d7 100644
--- a/regression-test/suites/datatype_p0/decimalv3/test_load.groovy
+++ b/regression-test/suites/datatype_p0/decimalv3/test_load.groovy
@@ -22,10 +22,6 @@ import java.nio.file.Files
 import java.nio.file.Paths
 
 suite("test_load") {
-    def dbName = "test_load"
-    sql "CREATE DATABASE IF NOT EXISTS ${dbName}"
-    sql "USE $dbName"
-
     def tableName = "test_decimal_load"
     try {
         sql """ DROP TABLE IF EXISTS ${tableName} """
@@ -41,16 +37,23 @@ suite("test_load") {
         );
         """
 
-        StringBuilder commandBuilder = new StringBuilder()
-        commandBuilder.append("""curl --max-time 5 --location-trusted -u ${context.config.feHttpUser}:${context.config.feHttpPassword}""")
-        commandBuilder.append(""" -H format:csv -T ${context.file.parent}/test_data/test.csv http://${context.config.feHttpAddress}/api/""" + dbName + "/" + tableName + "/_stream_load")
-        command = commandBuilder.toString()
-        process = command.execute()
-        code = process.waitFor()
-        err = IOGroovyMethods.getText(new BufferedReader(new InputStreamReader(process.getErrorStream())))
-        out = process.getText()
-        logger.info("Run command: command=" + command + ",code=" + code + ", out=" + out + ", err=" + err)
-        assertEquals(code, 0)
+        streamLoad {
+            table "${tableName}"
+
+            file 'test.csv'
+            time 10000 // limit inflight 10s
+
+            check { result, exception, startTime, endTime ->
+                if (exception != null) {
+                    throw exception
+                }
+                log.info("Stream load result: ${result}".toString())
+                def json = parseJson(result)
+                assertEquals("success", json.Status.toLowerCase())
+                assertEquals(3, json.NumberTotalRows)
+                assertEquals(0, json.NumberFilteredRows)
+            }
+        }
 
         sql """sync"""
         qt_select_default """ SELECT * FROM ${tableName} t ORDER BY a; """