From 635782b1bdbac2a19b90969560c77b82837ff29c Mon Sep 17 00:00:00 2001 From: xy720 Date: Thu, 27 May 2021 21:12:16 +0800 Subject: [PATCH] save code --- .../java/org/apache/doris/task/ExportExportingTask.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/task/ExportExportingTask.java b/fe/fe-core/src/main/java/org/apache/doris/task/ExportExportingTask.java index e8c9991fabadc7..744a4806e1cbbd 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/task/ExportExportingTask.java +++ b/fe/fe-core/src/main/java/org/apache/doris/task/ExportExportingTask.java @@ -135,7 +135,10 @@ protected void exec() { DebugUtil.printId(coord.getQueryId()), job.getId(), progress); } - coord.getQueryProfile().getCounterTotalTime().setValue(TimeUtils.getEstimatedTime(job.getStartTimeMs())); + RuntimeProfile queryProfile = coord.getQueryProfile(); + if (queryProfile != null) { + queryProfile.getCounterTotalTime().setValue(TimeUtils.getEstimatedTime(job.getStartTimeMs())); + } coord.endProfile(); fragmentProfiles.add(coord.getQueryProfile()); } @@ -248,8 +251,7 @@ public synchronized void onTimeout() { private void initProfile() { profile = new RuntimeProfile("Query"); - RuntimeProfile summaryProfile = new RuntimeProfile("Query"); - summaryProfile = new RuntimeProfile("Summary"); + RuntimeProfile summaryProfile = new RuntimeProfile("Summary"); summaryProfile.addInfoString(ProfileManager.QUERY_ID, String.valueOf(job.getId())); summaryProfile.addInfoString(ProfileManager.START_TIME, TimeUtils.longToTimeString(job.getStartTimeMs()));