diff --git service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java index 04fc0a1..6414351 100644 --- service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java +++ service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java @@ -427,6 +427,10 @@ private synchronized void cleanup(OperationState state) throws HiveSQLException @Override public void cancel(OperationState stateAfterCancel) throws HiveSQLException { + if (stateAfterCancel == OperationState.CANCELED) { + String queryId = confOverlay.get(HiveConf.ConfVars.HIVEQUERYID.varname); + LOG.info("Cancelling the query execution: " + queryId); + } cleanup(stateAfterCancel); cleanupOperationLog(); }