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 e6f23b8c3..1232cea27 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 @@ -111,7 +111,7 @@ public class SaveToHBaseChain implements IStorageChain { } else { columnName = buriedPointEntry.getParentLevel() + "." + buriedPointEntry.getLevelId(); if (buriedPointEntry.isReceiver()) { - columnName = buriedPointEntry.getLevelId() + "-S"; + columnName = buriedPointEntry.getParentLevel() + "." + buriedPointEntry.getLevelId() + "-S"; } put.addColumn(Bytes.toBytes(Config.HBaseConfig.FAMILY_COLUMN_NAME), Bytes.toBytes(columnName), Bytes.toBytes(buriedPointEntry.getOriginData()));