1

liugddx · Dec 5, 2023 · 4152204 · 4152204
1 parent ecfefa1
commit 4152204
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java
@@ -434,7 +434,7 @@ public void analyze(Analyzer analyzer) throws UserException {
                     String location = brokerDesc.getFileLocation(dataDescription.getFilePaths().get(i));
                     dataDescription.getFilePaths().set(i, location);
                     StorageBackend.checkPath(dataDescription.getFilePaths().get(i),
-                            brokerDesc.getStorageType(), null);
+                            brokerDesc.getStorageType(), "DATA INFILE must be specified.");
                     dataDescription.getFilePaths().set(i, dataDescription.getFilePaths().get(i));
                 }
             }

diff --git a/regression-test/suites/load_p0/broker_load/test_broker_load_without_filepath.groovy b/regression-test/suites/load_p0/broker_load/test_broker_load_without_filepath.groovy
@@ -19,6 +19,8 @@ suite("test_broker_load_without_filepath", "load_p0") {
     // define a sql table
     def testTable = "tbl_test_broker_load_without_filepath"
 
+    def a = 0;
+
     def create_test_table = {testTablex ->
         def result1 = sql """
             CREATE TABLE IF NOT EXISTS ${testTable} (
@@ -52,7 +54,8 @@ suite("test_broker_load_without_filepath", "load_p0") {
     }
 
     def load_from_hdfs_norm = {testTablex, label, hdfsFilePath, format, brokerName, hdfsUser, hdfsPasswd ->
-        try {
+
+        test {
             sql """
                         LOAD LABEL ${label} (
                             DATA INFILE("${hdfsFilePath}")
@@ -67,10 +70,9 @@ suite("test_broker_load_without_filepath", "load_p0") {
                         "timeout"="1200",
                         "max_filter_ratio"="0.1");
                         """
-        }catch (Exception e) {
-            log.info(e.getMessage())
-            assertTrue(e.getMessage().contains("DATA INFILE must be specified."))
+            exception "DATA INFILE must be specified."
         }
+
     }
 
     // if 'enableHdfs' in regression-conf.groovy has been set to true,