Skip to content

Commit 6016021

Browse files
committed
[fix](profile) Fix npe when updating profile for internal load task. (#40990)
Fix problem ``` 2024-09-19 15:39:08,025 WARN (mtmv-task-execute-1-thread-1|131) [StmtExecutor.updateProfile():1225] failed to update profile, ignore th is error java.lang.NullPointerException: Cannot read field "originStmt" because "this.originStmt" is null at org.apache.doris.qe.StmtExecutor.getSummaryInfo(StmtExecutor.java:402) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.StmtExecutor.updateProfile(StmtExecutor.java:1219) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.nereids.trees.plans.commands.insert.AbstractInsertExecutor.executeSingleInsert(AbstractInsertExecutor.java: 193) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.nereids.trees.plans.commands.insert.InsertIntoTableCommand.runInternal(InsertIntoTableCommand.java:250) ~[d oris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.nereids.trees.plans.commands.insert.InsertIntoTableCommand.run(InsertIntoTableCommand.java:117) ~[doris-fe. jar:1.2-SNAPSHOT] at org.apache.doris.nereids.trees.plans.commands.insert.InsertOverwriteTableCommand.runInsertCommand(InsertOverwriteTableComman d.java:204) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.nereids.trees.plans.commands.insert.InsertOverwriteTableCommand.insertInto(InsertOverwriteTableCommand.java :267) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.nereids.trees.plans.commands.insert.InsertOverwriteTableCommand.run(InsertOverwriteTableCommand.java:175) ~ [doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.job.extensions.mtmv.MTMVTask.exec(MTMVTask.java:231) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.job.extensions.mtmv.MTMVTask.run(MTMVTask.java:200) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.job.task.AbstractTask.runTask(AbstractTask.java:167) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.job.extensions.mtmv.MTMVTask.runTask(MTMVTask.java:306) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.job.executor.DefaultTaskExecutorHandler.onEvent(DefaultTaskExecutorHandler.java:50) ~[doris-fe.jar:1.2-SNAP SHOT] at org.apache.doris.job.executor.DefaultTaskExecutorHandler.onEvent(DefaultTaskExecutorHandler.java:33) ~[doris-fe.jar:1.2-SNAP SHOT] at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143) ~[disruptor-3.4.4.jar:?] at java.lang.Thread.run(Thread.java:842) ~[?:?] ```
1 parent dbd72de commit 6016021

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -379,7 +379,7 @@ private Map<String, String> getSummaryInfo(boolean isFinished) {
379379
builder.defaultCatalog(context.getCurrentCatalog().getName());
380380
builder.defaultDb(context.getDatabase());
381381
builder.workloadGroup(context.getWorkloadGroupName());
382-
builder.sqlStatement(originStmt.originStmt);
382+
builder.sqlStatement(originStmt == null ? "" : originStmt.originStmt);
383383
builder.isCached(isCached ? "Yes" : "No");
384384

385385
Map<String, Integer> beToInstancesNum = coord == null ? Maps.newTreeMap() : coord.getBeToInstancesNum();

0 commit comments

Comments
 (0)