Repository: kylin Updated Branches: refs/heads/yang-m1 3eeabeb51 -> bb1b6c3f9
KYLIN-1578 Coprocessor thread voluntarily stop itself when it reaches timeout Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/bb1b6c3f Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/bb1b6c3f Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/bb1b6c3f Branch: refs/heads/yang-m1 Commit: bb1b6c3f97e36e1b473c0ba33c6544c1debcacee Parents: 3eeabeb Author: Hongbin Ma <mahong...@apache.org> Authored: Tue Apr 12 10:32:32 2016 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Tue Apr 12 10:32:32 2016 +0800 ---------------------------------------------------------------------- .../hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/bb1b6c3f/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java ---------------------------------------------------------------------- diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java index 0879661..9dfc607 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java @@ -250,10 +250,10 @@ public class CubeVisitService extends CubeVisitProtos.CubeVisitService implement byte[] compressedAllRows; if (normalComplete.booleanValue()) { allRows = outputStream.toByteArray(); - compressedAllRows = CompressionUtils.compress(allRows); } else { - compressedAllRows = new byte[0]; + allRows = new byte[0]; } + compressedAllRows = CompressionUtils.compress(allRows); appendProfileInfo(sb, "compress done");
