Repository: lens
Updated Branches:
  refs/heads/master 72f128f90 -> e842ce13e


LENS-1242: (incremental)JDBCDriver cancel query is taking huge time


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

Branch: refs/heads/master
Commit: e842ce13e5ed88a0f278c198412b9c2cd758819d
Parents: 72f128f
Author: Amareshwari Sriramadasu <amareshw...@gmail.com>
Authored: Mon Aug 1 17:18:21 2016 +0530
Committer: Rajat Khandelwal <rajatgupt...@gmail.com>
Committed: Mon Aug 1 17:18:21 2016 +0530

----------------------------------------------------------------------
 .../src/main/java/org/apache/lens/driver/jdbc/JDBCDriver.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/lens/blob/e842ce13/lens-driver-jdbc/src/main/java/org/apache/lens/driver/jdbc/JDBCDriver.java
----------------------------------------------------------------------
diff --git 
a/lens-driver-jdbc/src/main/java/org/apache/lens/driver/jdbc/JDBCDriver.java 
b/lens-driver-jdbc/src/main/java/org/apache/lens/driver/jdbc/JDBCDriver.java
index 15a1826..bebb9ae 100644
--- a/lens-driver-jdbc/src/main/java/org/apache/lens/driver/jdbc/JDBCDriver.java
+++ b/lens-driver-jdbc/src/main/java/org/apache/lens/driver/jdbc/JDBCDriver.java
@@ -217,7 +217,7 @@ public class JDBCDriver extends AbstractLensDriver {
       log.debug("Done resultFuture cancel!");
       // queryResult object would be null if query is not yet launched - since 
we did future.cancel, no other cancel is
       // required.
-      if (queryResult != null && isStatementCancelSupported) {
+      if (queryResult != null && queryResult.stmt != null && 
isStatementCancelSupported) {
         log.debug("Cancelling query through statement cancel");
         try {
           queryResult.stmt.cancel();

Reply via email to