This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new 3dd40f541d7 branch-4.1: [fix](load) fix empty statistics for forwarded
INSERT #64439 (#64453)
3dd40f541d7 is described below
commit 3dd40f541d79fb9a95115d43e8cfd349301f12da
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Jun 15 12:12:14 2026 +0800
branch-4.1: [fix](load) fix empty statistics for forwarded INSERT #64439
(#64453)
Cherry-picked from #64439
Co-authored-by: hui lai <[email protected]>
---
fe/fe-core/src/main/java/org/apache/doris/catalog/EnvFactory.java | 2 +-
.../main/java/org/apache/doris/cloud/catalog/CloudEnvFactory.java | 2 +-
.../src/main/java/org/apache/doris/cloud/qe/CloudCoordinator.java | 5 +++++
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 6 ++++++
4 files changed, 13 insertions(+), 2 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/EnvFactory.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/EnvFactory.java
index 3ecdb6ddef3..8a4e0dcb331 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/EnvFactory.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/EnvFactory.java
@@ -156,7 +156,7 @@ public class EnvFactory {
if (planner instanceof NereidsPlanner &&
SessionVariable.canUseNereidsDistributePlanner(context)) {
return new NereidsCoordinator(context, (NereidsPlanner) planner,
statsErrorEstimator, jobId);
}
- return new Coordinator(context, planner, statsErrorEstimator);
+ return new Coordinator(context, planner, statsErrorEstimator, jobId);
}
// Used for broker load task/export task/update coordinator
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudEnvFactory.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudEnvFactory.java
index 5b240dcd8ef..437c1cc0ba2 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudEnvFactory.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudEnvFactory.java
@@ -170,7 +170,7 @@ public class CloudEnvFactory extends EnvFactory {
if (planner instanceof NereidsPlanner &&
SessionVariable.canUseNereidsDistributePlanner()) {
return new NereidsCoordinator(context, (NereidsPlanner) planner,
statsErrorEstimator, jobId);
}
- return new CloudCoordinator(context, planner, statsErrorEstimator);
+ return new CloudCoordinator(context, planner, statsErrorEstimator,
jobId);
}
@Override
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/qe/CloudCoordinator.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/qe/CloudCoordinator.java
index 92b3ff4c0ac..39eb6d36ede 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/cloud/qe/CloudCoordinator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/cloud/qe/CloudCoordinator.java
@@ -45,6 +45,11 @@ public class CloudCoordinator extends Coordinator {
super(context, planner, statsErrorEstimator);
}
+ public CloudCoordinator(ConnectContext context,
+ Planner planner, StatsErrorEstimator
statsErrorEstimator, long jobId) {
+ super(context, planner, statsErrorEstimator, jobId);
+ }
+
public CloudCoordinator(Long jobId, TUniqueId queryId, DescriptorTable
descTable, List<PlanFragment> fragments,
List<ScanNode> scanNodes, String timezone, boolean
loadZeroTolerance,
boolean enbaleProfile) {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
index 0449ffcdfb4..16bbc6a3397 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -332,6 +332,12 @@ public class Coordinator implements CoordInterface {
this.statsErrorEstimator = statsErrorEstimator;
}
+ public Coordinator(ConnectContext context, Planner planner,
+ StatsErrorEstimator statsErrorEstimator, long jobId) {
+ this(context, planner, statsErrorEstimator);
+ this.jobId = jobId;
+ }
+
// Used for query/insert/test
public Coordinator(ConnectContext context, Planner planner) {
this.context = context;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
