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 66fb9389c..05bcb6d62 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 @@ -73,14 +73,14 @@ public class SaveToHBaseChain implements IStorageChain { } - private static void bulkInsertBuriedPointData(List spans) { + public static void bulkInsertBuriedPointData(List spans) { if (spans == null || spans.size() <= 0) return; List puts = new ArrayList(); Put put; String columnName; for (Span span : spans) { - put = new Put(Bytes.toBytes(span.getTraceId())); + put = new Put(Bytes.toBytes(span.getTraceId()), getTSBySpanTraceId(span)); if (StringUtils.isEmpty(span.getParentLevel().trim())) { columnName = span.getLevelId() + ""; if (span.isReceiver()) { @@ -104,6 +104,10 @@ public class SaveToHBaseChain implements IStorageChain { ServerHealthCollector.getCurrentHeathReading("hbase").updateData(ServerHeathReading.INFO, "save " + spans.size() + " BuriedPointEntries."); } + private static long getTSBySpanTraceId(Span span) { + return Long.parseLong(span.getTraceId().split("\\.")[2]); + } + private static void bulkInsertBuriedPointData(String tableName, List data) { Object[] resultArrays = new Object[data.size()]; try {