Repository: kylin Updated Branches: refs/heads/mhb_test_1 7c154921e -> 5fd272892
bug fix Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/5fd27289 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/5fd27289 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/5fd27289 Branch: refs/heads/mhb_test_1 Commit: 5fd2728929ff29a90b062fe6a97049178149e86f Parents: 7c15492 Author: Hongbin Ma <mahong...@apache.org> Authored: Wed Apr 27 13:11:01 2016 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Wed Apr 27 13:11:01 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/5fd27289/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 f554dac..75cc977 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 @@ -322,6 +322,7 @@ public class CubeHBaseEndpointRPC extends CubeHBaseRPC { final AtomicInteger totalScannedCount = new AtomicInteger(0); final ExpectedSizeIterator epResultItr = new ExpectedSizeIterator(scanRequests.size() * shardNum); final AtomicInteger atomicInteger = new AtomicInteger(0); + final String storageResultDumpPath = BackdoorToggles.getStorageResultDump();//usually it's null for (final Pair<byte[], byte[]> epRange : getEPKeyRanges(cuboidBaseShard, shardNum, totalShards)) { executorService.submit(new Runnable() { @@ -358,7 +359,7 @@ public class CubeHBaseEndpointRPC extends CubeHBaseRPC { int order = atomicInteger.incrementAndGet(); byte[] compressed = HBaseZeroCopyByteString.zeroCopyGetBytes(result.getValue().getCompressedRows()); logger.info("Checking BackdoorToggles.getStorageResultDump()"); - if (BackdoorToggles.getStorageResultDump() != null) { + if (storageResultDumpPath != null) { try { FileUtils.writeByteArrayToFile(new File(BackdoorToggles.getStorageResultDump() + "/" + order), compressed); logger.info("write to file for part " + order + " finished");
