You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2016/04/14 14:23:51 UTC
kylin git commit: print debug git tag in coprocessor
Repository: kylin
Updated Branches:
refs/heads/yang-m1 aeacd9732 -> c37858875
print debug git tag in coprocessor
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/c3785887
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/c3785887
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/c3785887
Branch: refs/heads/yang-m1
Commit: c37858875daf9fe2038ecdf2337ade3dc018fd7a
Parents: aeacd97
Author: Hongbin Ma <ma...@apache.org>
Authored: Thu Apr 14 20:23:43 2016 +0800
Committer: Hongbin Ma <ma...@apache.org>
Committed: Thu Apr 14 20:23:43 2016 +0800
----------------------------------------------------------------------
.../hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/c3785887/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 753e9d3..1e57633 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
@@ -48,6 +48,7 @@ import org.apache.kylin.gridtable.IGTScanner;
import org.apache.kylin.gridtable.IGTStore;
import org.apache.kylin.metadata.filter.UDF.MassInTupleFilter;
import org.apache.kylin.metadata.model.TblColRef;
+import org.apache.kylin.metadata.realization.IRealizationConstants;
import org.apache.kylin.storage.hbase.common.coprocessor.CoprocessorBehavior;
import org.apache.kylin.storage.hbase.cube.v2.CellListIterator;
import org.apache.kylin.storage.hbase.cube.v2.CubeHBaseRPC;
@@ -170,12 +171,14 @@ public class CubeVisitService extends CubeVisitProtos.CubeVisitService implement
StringBuilder sb = new StringBuilder();
byte[] allRows;
+ String debugGitTag = "";
try {
this.serviceStartTime = System.currentTimeMillis();
region = env.getRegion();
region.startRegionOperation();
+ debugGitTag = region.getTableDesc().getValue(IRealizationConstants.HTableGitTag);
final GTScanRequest scanReq = GTScanRequest.serializer.deserialize(ByteBuffer.wrap(HBaseZeroCopyByteString.zeroCopyGetBytes(request.getGtScanRequest())));
final RawScan hbaseRawScan = RawScan.serializer.deserialize(ByteBuffer.wrap(HBaseZeroCopyByteString.zeroCopyGetBytes(request.getHbaseRawScan())));
@@ -255,7 +258,6 @@ public class CubeVisitService extends CubeVisitProtos.CubeVisitService implement
}
compressedAllRows = CompressionUtils.compress(allRows);
-
appendProfileInfo(sb, "compress done");
OperatingSystemMXBean operatingSystemMXBean = (OperatingSystemMXBean) ManagementFactory.getOperatingSystemMXBean();
@@ -265,6 +267,8 @@ public class CubeVisitService extends CubeVisitProtos.CubeVisitService implement
appendProfileInfo(sb, "server stats done");
+ sb.append(" debugGitTag:" + debugGitTag);
+
CubeVisitProtos.CubeVisitResponse.Builder responseBuilder = CubeVisitProtos.CubeVisitResponse.newBuilder();
done.run(responseBuilder.//
setCompressedRows(HBaseZeroCopyByteString.wrap(compressedAllRows)).//too many array copies