You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2021/07/03 02:30:43 UTC
[skywalking] branch service_traffic_timebucket created (now a388eee)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch service_traffic_timebucket
in repository https://gitbox.apache.org/repos/asf/skywalking.git.
at a388eee Fix, make sure time bucket exists in service traffic.
This branch includes the following new commits:
new a388eee Fix, make sure time bucket exists in service traffic.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[skywalking] 01/01: Fix,
make sure time bucket exists in service traffic.
Posted by wu...@apache.org.
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 <wu...@foxmail.com>
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;
}
}