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/7ae4a547 Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/7ae4a547 Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/7ae4a547 Branch: refs/heads/master Commit: 7ae4a547294e23ec0b61d89679c9137f86709fb2 Parents: f330010 Author: Amareshwari Sriramadasu <[email protected]> Authored: Mon Aug 1 17:18:21 2016 +0530 Committer: Amareshwari Sriramadasu <[email protected]> Committed: Tue Aug 2 09:37:31 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/7ae4a547/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();
