Repository: kylin Updated Branches: refs/heads/yang-m1 d291e8473 -> c1af3c015
KYLIN-1579 bug fix Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/c1af3c01 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/c1af3c01 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/c1af3c01 Branch: refs/heads/yang-m1 Commit: c1af3c015549faacd7968a54a8ef14c767f6b83b Parents: d291e84 Author: Hongbin Ma <mahong...@apache.org> Authored: Tue Apr 12 15:49:09 2016 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Tue Apr 12 15:49:09 2016 +0800 ---------------------------------------------------------------------- .../storage/hbase/cube/v2/CubeHBaseEndpointRPC.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/c1af3c01/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 554a764..cf39641 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 @@ -333,12 +333,12 @@ public class CubeHBaseEndpointRPC extends CubeHBaseRPC { if (result.getValue().getStats().getNormalComplete() != 1) { abnormalFinish = true; - } - - try { - epResultItr.append(CompressionUtils.decompress(HBaseZeroCopyByteString.zeroCopyGetBytes(result.getValue().getCompressedRows()))); - } catch (IOException | DataFormatException e) { - throw new RuntimeException(logHeader + "Error when decompressing", e); + } else { + try { + epResultItr.append(CompressionUtils.decompress(HBaseZeroCopyByteString.zeroCopyGetBytes(result.getValue().getCompressedRows()))); + } catch (IOException | DataFormatException e) { + throw new RuntimeException(logHeader + "Error when decompressing", e); + } } }
