bug fix
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/f75859fd
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/f75859fd
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/f75859fd
Branch: refs/heads/mhb-master
Commit: f75859fdb4a6d39dc8252df82241eecd8e9dcb10
Parents: aff694e
Author: Hongbin Ma <mahongbin@apache.org>
Authored: Sun Dec 25 14:51:08 2016 +0800
Committer: Hongbin Ma <mahongbin@apache.org>
Committed: Mon Dec 26 20:13:06 2016 +0800
----------------------------------------------------------------------
.../org/apache/kylin/query/enumerator/OLAPEnumerator.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/f75859fd/query/src/main/java/org/apache/kylin/query/enumerator/OLAPEnumerator.java
----------------------------------------------------------------------
diff --git a/query/src/main/java/org/apache/kylin/query/enumerator/OLAPEnumerator.java b/query/src/main/java/org/apache/kylin/query/enumerator/OLAPEnumerator.java
index 408d227..e4fc937 100644
--- a/query/src/main/java/org/apache/kylin/query/enumerator/OLAPEnumerator.java
+++ b/query/src/main/java/org/apache/kylin/query/enumerator/OLAPEnumerator.java
@@ -76,14 +76,15 @@ public class OLAPEnumerator implements Enumerator<Object[]> {
}
convertCurrentRow(tuple);
return true;
- } finally {
+ } catch (Exception e) {
try {
if (cursor != null) {
cursor.close();
}
- } catch (Exception e) {
- logger.info("Error when closing cursor, ignore it", e);
+ } catch (Exception ee) {
+ logger.info("Error when closing cursor, ignore it", ee);
}
+ throw e;
}
}
|