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

morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-3.1 by this push:
     new 300f92842f4 branch-3.1: [fix](nereids) insert task should set 
isNereids to true in ConnectContext #53919 (#54142)
300f92842f4 is described below

commit 300f92842f48f998e48225c1e71ffc845ea4df7f
Author: starocean999 <[email protected]>
AuthorDate: Fri Aug 1 10:11:22 2025 +0800

    branch-3.1: [fix](nereids) insert task should set isNereids to true in 
ConnectContext #53919 (#54142)
    
    pick from #53919
---
 .../src/main/java/org/apache/doris/job/extensions/insert/InsertTask.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/InsertTask.java
 
b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/InsertTask.java
index c38135eb03b..c048732e9fd 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/InsertTask.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/InsertTask.java
@@ -157,6 +157,7 @@ public class InsertTask extends AbstractTask {
         ctx.setCurrentUserIdentity(userIdentity);
         ctx.getState().reset();
         ctx.getState().setInternal(true);
+        ctx.getState().setNereids(true);
         ctx.setThreadLocalInfo();
         if (StringUtils.isNotEmpty(currentDb)) {
             ctx.setDatabase(currentDb);


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to