morrySnow commented on code in PR #64366:
URL: https://github.com/apache/doris/pull/64366#discussion_r3518731389
##########
fe/fe-core/src/main/java/org/apache/doris/nereids/load/NereidsLoadingTaskPlanner.java:
##########
@@ -215,6 +212,14 @@ public void plan(TUniqueId loadId,
List<List<TBrokerFileStatus>> fileStatusesLis
Collections.reverse(fragments);
}
+ static void installBrokerLoadStatementContext(ConnectContext
connectContext,
Review Comment:
Fixed in 3bd0f4ebf16. Broker load planning now saves the original
`StatementContext`, installs a task context only for planning, and restores the
original context in `finally` using the same restore helper pattern as stream
load. I also store `NereidsBrokerLoadTask.getStatementStartTime()` on the
planner and pass it through `LoadLoadingTask.executeOnce()` into the new
`EnvFactory.createCoordinator(..., statementStartTime)` overload, so FE pruning
and BE row filtering use the same task instant. The broker load unit test now
verifies restore behavior.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
