morrySnow commented on code in PR #64366:
URL: https://github.com/apache/doris/pull/64366#discussion_r3418154688
##########
fe/fe-core/src/main/java/org/apache/doris/nereids/load/NereidsBrokerLoadTask.java:
##########
@@ -25,12 +25,14 @@
import org.apache.doris.thrift.TFileFormatType;
import org.apache.doris.thrift.TFileType;
+import java.time.Instant;
import java.util.List;
/**
* Nereids Broker Load Task
*/
public class NereidsBrokerLoadTask implements NereidsLoadTaskInfo {
+ private final Instant statementStartTime = Instant.now();
Review Comment:
Fixed in 28d1b2273e3. The broker load planner now constructs the
NereidsBrokerLoadTask first, then installs that task statementStartTime into
the current ConnectContext StatementContext via
NereidsLoadingTaskPlanner.installBrokerLoadStatementContext(). This makes
NereidsLoadPlanInfoCollector and the later EnvFactory.createCoordinator() path
read the same statement timestamp instead of using a stale or freshly-created
context time. I also added a unit test that starts with an existing old
StatementContext and verifies it is replaced with the broker load task
timestamp.
--
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]
