[doris] branch master updated: [fix](load) fix unified load redirect status delegate error (#20467)

[dataroaring]

This is an automated email from the ASF dual-hosted git repository.

dataroaring 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 48021366bf [fix](load) fix unified load redirect status delegate error 
(#20467)
48021366bf is described below

commit 48021366bffcdcad264b76a648f8758d7e9ba309
Author: lvshaokang <lvshaok...@hotmail.com>
AuthorDate: Tue Jun 6 15:46:48 2023 +0800

    [fix](load) fix unified load redirect status delegate error (#20467)
---
 .../src/main/java/org/apache/doris/analysis/UnifiedLoadStmt.java  | 5 +++++
 .../src/test/java/org/apache/doris/analysis/LoadStmtTest.java     | 8 ++++++++
 2 files changed, 13 insertions(+)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/analysis/UnifiedLoadStmt.java 
b/fe/fe-core/src/main/java/org/apache/doris/analysis/UnifiedLoadStmt.java
index 4b395f1f5e..8a58ee9523 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/UnifiedLoadStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/UnifiedLoadStmt.java
@@ -64,4 +64,9 @@ public class UnifiedLoadStmt extends DdlStmt {
     public StatementBase getProxyStmt() {
         return proxyStmt;
     }
+
+    @Override
+    public RedirectStatus getRedirectStatus() {
+        return proxyStmt.getRedirectStatus();
+    }
 }
diff --git 
a/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java 
b/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java
index cd8fc4be26..59070dc80c 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java
@@ -239,6 +239,14 @@ public class LoadStmtTest {
         stmt.analyze(analyzer);
         Assert.assertNull(stmt.getLabel().getDbName());
         Assert.assertEquals(EtlJobType.LOCAL_FILE, stmt.getEtlJobType());
+
+        // unified load stmt
+        UnifiedLoadStmt unifiedStmt = UnifiedLoadStmt.buildMysqlLoadStmt(desc, 
Maps.newHashMap(), "");
+        Config.mysql_load_server_secure_path = "/";
+        unifiedStmt.analyze(analyzer);
+        Assert.assertTrue(unifiedStmt.getProxyStmt() instanceof LoadStmt);
+        Assert.assertNull(((LoadStmt) 
unifiedStmt.getProxyStmt()).getLabel().getDbName());
+        Assert.assertEquals(unifiedStmt.getRedirectStatus(), 
RedirectStatus.NO_FORWARD);
     }
 
     @Test


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org