bug fix
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/473f77b0 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/473f77b0 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/473f77b0 Branch: refs/heads/yang22-hbase102 Commit: 473f77b06a1554aedbfcfd4fc5b827087aadb426 Parents: 83f9dc7 Author: Hongbin Ma <mahong...@apache.org> Authored: Sun Dec 25 14:51:08 2016 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Sun Dec 25 14:51:08 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/473f77b0/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; } }
