From f98728391e65c4e98a2a1004301df68be666e5f5 Mon Sep 17 00:00:00 2001 From: ascrutae Date: Sat, 2 Jul 2016 12:31:11 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9RPC=E6=9C=8D=E5=8A=A1?= =?UTF-8?q?=E7=AB=AF=E4=B8=8D=E5=9C=A8=E5=BA=8F=E5=8F=B7=E4=B9=8B=E5=90=8E?= =?UTF-8?q?=E5=8A=A0=E4=B8=8A-S=E6=A0=87=E8=AF=86=E7=AC=A6=E4=BA=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../reciever/storage/chain/SaveToHBaseChain.java | 7 ------- 1 file changed, 7 deletions(-) diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java index 3a8b50e9a..6f44b1663 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java @@ -105,19 +105,12 @@ public class SaveToHBaseChain implements IStorageChain { try { if (StringUtils.isEmpty(span.getParentLevel().trim())) { columnName = span.getLevelId() + ""; - if (span.isReceiver()) { - columnName = span.getLevelId() + "-S"; - } put.addColumn( Bytes.toBytes(Config.HBaseConfig.FAMILY_COLUMN_NAME), Bytes.toBytes(columnName), Bytes.toBytes(span.getOriginData())); } else { columnName = span.getParentLevel() + "." + span.getLevelId(); - if (span.isReceiver()) { - columnName = span.getParentLevel() + "." - + span.getLevelId() + "-S"; - } put.addColumn( Bytes.toBytes(Config.HBaseConfig.FAMILY_COLUMN_NAME), Bytes.toBytes(columnName),