Return-Path: X-Original-To: apmail-kylin-commits-archive@minotaur.apache.org Delivered-To: apmail-kylin-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 0EDAB193AA for ; Thu, 14 Apr 2016 12:23:52 +0000 (UTC) Received: (qmail 53389 invoked by uid 500); 14 Apr 2016 12:23:52 -0000 Delivered-To: apmail-kylin-commits-archive@kylin.apache.org Received: (qmail 53339 invoked by uid 500); 14 Apr 2016 12:23:51 -0000 Mailing-List: contact commits-help@kylin.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kylin.apache.org Delivered-To: mailing list commits@kylin.apache.org Received: (qmail 53330 invoked by uid 99); 14 Apr 2016 12:23:51 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 14 Apr 2016 12:23:51 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 4046FDFCDF; Thu, 14 Apr 2016 12:23:51 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: mahongbin@apache.org To: commits@kylin.apache.org Message-Id: <452fbae534eb46378af6185de718ddd4@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: kylin git commit: print debug git tag in coprocessor Date: Thu, 14 Apr 2016 12:23:51 +0000 (UTC) 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 Authored: Thu Apr 14 20:23:43 2016 +0800 Committer: Hongbin Ma 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