You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lens.apache.org by pu...@apache.org on 2016/10/25 10:25:00 UTC
[02/31] lens git commit: LENS-1242: (incremental)JDBCDriver cancel
query is taking huge time
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 <am...@gmail.com>
Authored: Mon Aug 1 17:18:21 2016 +0530
Committer: Amareshwari Sriramadasu <am...@apache.org>
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();