You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2016/06/22 03:29:12 UTC

kylin git commit: KYLIN-1645 Fix logging

Repository: kylin
Updated Branches:
  refs/heads/master a80a0f734 -> ce7fcdf37


KYLIN-1645 Fix logging


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

Branch: refs/heads/master
Commit: ce7fcdf37bcf6d1298b5cfe07b7ff148c195c59f
Parents: a80a0f7
Author: Li Yang <li...@apache.org>
Authored: Wed Jun 22 11:29:02 2016 +0800
Committer: Li Yang <li...@apache.org>
Committed: Wed Jun 22 11:29:02 2016 +0800

----------------------------------------------------------------------
 .../apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/ce7fcdf3/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java
index bacf6e2..42e2149 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java
@@ -397,13 +397,14 @@ public class CubeHBaseEndpointRPC extends CubeHBaseRPC {
                                 });
 
                     } catch (Throwable ex) {
-                        logger.error(logHeader + "Error when visiting cubes by endpoint", ex);
+                        logger.error(logHeader + "Error when visiting cubes by endpoint", ex); // double log coz the query thread may already timeout
                         epResultItr.notifyCoprocException(ex);
                         return;
                     }
 
                     if (abnormalFinish[0]) {
                         Throwable ex = new RuntimeException(logHeader + "The coprocessor thread stopped itself due to scan timeout, failing current query...");
+                        logger.error(logHeader + "Error when visiting cubes by endpoint", ex); // double log coz the query thread may already timeout
                         epResultItr.notifyCoprocException(ex);
                         return;
                     }