You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by am...@apache.org on 2018/01/21 19:44:06 UTC
[2/4] drill git commit: DRILL-6081: Set query end time before writing
final profile
DRILL-6081: Set query end time before writing final profile
close apache/drill#1088
Project: http://git-wip-us.apache.org/repos/asf/drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/3ff958cb
Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/3ff958cb
Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/3ff958cb
Branch: refs/heads/master
Commit: 3ff958cbcac644685f0c6e984eb4764c55e226f3
Parents: 81f926b
Author: Arina Ielchiieva <ar...@gmail.com>
Authored: Thu Jan 11 17:40:04 2018 +0200
Committer: Aman Sinha <as...@maprtech.com>
Committed: Sun Jan 21 08:32:46 2018 -0800
----------------------------------------------------------------------
.../main/java/org/apache/drill/exec/work/foreman/Foreman.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/drill/blob/3ff958cb/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java b/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java
index 276d839..5633022 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java
@@ -746,6 +746,9 @@ public class Foreman implements Runnable {
});
}
+ // set query end time before writing final profile
+ queryStateProcessor.close();
+
/*
* Construct the response based on the latest resultState. The builder shouldn't fail.
*/
@@ -813,8 +816,6 @@ public class Foreman implements Runnable {
logger.warn("unable to close query manager", e);
}
- queryStateProcessor.close();
-
try {
queryRM.exit();
} finally {