This is an automated email from the ASF dual-hosted git repository. wusheng pushed a commit to branch service_traffic_timebucket in repository https://gitbox.apache.org/repos/asf/skywalking.git
commit a388eeecaf50ebb83457afbb188aeb52b90db19d Author: Wu Sheng <[email protected]> AuthorDate: Sat Jul 3 10:30:25 2021 +0800 Fix, make sure time bucket exists in service traffic. --- .../oap/server/core/analysis/manual/service/ServiceTraffic.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/service/ServiceTraffic.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/service/ServiceTraffic.java index d5ab808..ea7627c 100644 --- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/service/ServiceTraffic.java +++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/service/ServiceTraffic.java @@ -102,6 +102,7 @@ public class ServiceTraffic extends Metrics { serviceTraffic.setName((String) dbMap.get(NAME)); serviceTraffic.setNodeType(NodeType.valueOf(((Number) dbMap.get(NODE_TYPE)).intValue())); serviceTraffic.setGroup((String) dbMap.get(GROUP)); + serviceTraffic.setTimeBucket(((Number) dbMap.get(TIME_BUCKET)).longValue()); return serviceTraffic; } @@ -118,6 +119,7 @@ public class ServiceTraffic extends Metrics { map.put(NAME, serviceName); map.put(NODE_TYPE, storageData.getNodeType().value()); map.put(GROUP, storageData.getGroup()); + map.put(TIME_BUCKET, storageData.getTimeBucket()); return map; } }
