Repository: kylin Updated Branches: refs/heads/master e8e95fa04 -> 1b54a40bd
print coprocessor commit id Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/1b54a40b Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/1b54a40b Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/1b54a40b Branch: refs/heads/master Commit: 1b54a40bd397064576ed075d7bb074f658ccb995 Parents: e8e95fa Author: Hongbin Ma <mahong...@apache.org> Authored: Fri Apr 15 15:51:23 2016 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Fri Apr 15 15:58:48 2016 +0800 ---------------------------------------------------------------------- .../cube/v2/coprocessor/endpoint/CubeVisitService.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/1b54a40b/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 2f1bb9b..585908b 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 @@ -50,6 +50,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; @@ -168,12 +169,15 @@ 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()))); List<List<Integer>> hbaseColumnsToGT = Lists.newArrayList(); @@ -303,6 +307,8 @@ public class CubeVisitService extends CubeVisitProtos.CubeVisitService implement double freeSwapSpaceSize = operatingSystemMXBean.getFreeSwapSpaceSize(); appendProfileInfo(sb, "server stats done"); + sb.append(" debugGitTag:" + debugGitTag); + CubeVisitProtos.CubeVisitResponse.Builder responseBuilder = CubeVisitProtos.CubeVisitResponse.newBuilder(); done.run(responseBuilder.// @@ -323,7 +329,8 @@ public class CubeVisitService extends CubeVisitProtos.CubeVisitService implement } catch (IOException ioe) { logger.error(ioe.toString()); - ResponseConverter.setControllerException(controller, ioe); + IOException wrapped = new IOException("Error in coprocessor " + debugGitTag, ioe); + ResponseConverter.setControllerException(controller, wrapped); } finally { for (RegionScanner innerScanner : regionScanners) { IOUtils.closeQuietly(innerScanner);
