kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mahong...@apache.org
Subject kylin git commit: print debug git tag in coprocessor
Date Thu, 14 Apr 2016 12:23:51 GMT
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 <mahongbin@apache.org>
Authored: Thu Apr 14 20:23:43 2016 +0800
Committer: Hongbin Ma <mahongbin@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 


Mime
View raw message