hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xu...@apache.org
Subject hive git commit: HIVE-16286: Log canceled query id (Jimmy via Xuefu)
Date Fri, 24 Mar 2017 02:36:33 GMT
Repository: hive
Updated Branches:
  refs/heads/master 736d2e861 -> 8fa9d5833


HIVE-16286: Log canceled query id (Jimmy via Xuefu)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/8fa9d583
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/8fa9d583
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/8fa9d583

Branch: refs/heads/master
Commit: 8fa9d5833c5c4fda092a917c9881db8fbfea5332
Parents: 736d2e8
Author: Xuefu Zhang <xuefu@uber.com>
Authored: Thu Mar 23 19:36:16 2017 -0700
Committer: Xuefu Zhang <xuefu@uber.com>
Committed: Thu Mar 23 19:36:16 2017 -0700

----------------------------------------------------------------------
 .../org/apache/hive/service/cli/operation/SQLOperation.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/8fa9d583/service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java
----------------------------------------------------------------------
diff --git a/service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java b/service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java
index ff389ac..f41092e 100644
--- a/service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java
+++ b/service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java
@@ -172,8 +172,9 @@ public class SQLOperation extends ExecuteStatementOperation {
           @Override
           public void run() {
             try {
+              String queryId = confOverlay.get(HiveConf.ConfVars.HIVEQUERYID.varname);
               LOG.info("Query timed out after: " + queryTimeout
-                  + " seconds. Cancelling the execution now.");
+                  + " seconds. Cancelling the execution now: " + queryId);
               SQLOperation.this.cancel(OperationState.TIMEDOUT);
             } catch (HiveSQLException e) {
               LOG.error("Error cancelling the query after timeout: " + queryTimeout + " seconds",
e);
@@ -412,7 +413,8 @@ public class SQLOperation extends ExecuteStatementOperation {
       if (backgroundHandle != null) {
         boolean success = backgroundHandle.cancel(true);
         if (success) {
-          LOG.info("The running operation has been successfully interrupted.");
+          String queryId = confOverlay.get(HiveConf.ConfVars.HIVEQUERYID.varname);
+          LOG.info("The running operation has been successfully interrupted: " + queryId);
         }
       }
     }


Mime
View raw message