Service metric test ok.

apm-collector/apm-collector-analysis/analysis-metric/metric-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/metric/provider/worker/service/ServiceMetricAggregationWorker.java

@@ -42,8 +42,15 @@ public class ServiceMetricAggregationWorker extends AggregationWorker<ServiceRef
     @Override protected ServiceMetric transform(ServiceReferenceMetric serviceReferenceMetric) {
         Integer serviceId = serviceReferenceMetric.getBehindServiceId();
         Long timeBucket = serviceReferenceMetric.getTimeBucket();
-        ServiceMetric serviceMetric = new ServiceMetric(String.valueOf(timeBucket) + Const.ID_SPLIT + String.valueOf(serviceId));
+        Integer sourceValue = serviceReferenceMetric.getSourceValue();
+
+        String id = String.valueOf(timeBucket) + Const.ID_SPLIT + String.valueOf(serviceId) + Const.ID_SPLIT + String.valueOf(sourceValue);
+
+        ServiceMetric serviceMetric = new ServiceMetric(id);
+        serviceMetric.setApplicationId(serviceReferenceMetric.getBehindApplicationId());
+        serviceMetric.setInstanceId(serviceReferenceMetric.getBehindInstanceId());
         serviceMetric.setServiceId(serviceId);
+        serviceMetric.setSourceValue(sourceValue);
 
         serviceMetric.setTransactionCalls(serviceReferenceMetric.getTransactionCalls());
         serviceMetric.setTransactionDurationSum(serviceReferenceMetric.getTransactionDurationSum());

apm-collector/apm-collector-analysis/analysis-metric/metric-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/metric/provider/worker/service/ServiceReferenceMetricSpanListener.java

@@ -152,7 +152,7 @@ public class ServiceReferenceMetricSpanListener implements FirstSpanListener, En
         logger.debug("service reference listener build");
         Graph<ServiceReferenceMetric> graph = GraphManager.INSTANCE.findGraph(MetricGraphIdDefine.SERVICE_REFERENCE_METRIC_GRAPH_ID, ServiceReferenceMetric.class);
         entryReferenceMetric.forEach(serviceReferenceMetric -> {
-            String id = timeBucket + Const.ID_SPLIT + serviceReferenceMetric.getFrontServiceId() + Const.ID_SPLIT + serviceReferenceMetric.getBehindServiceId();
+            String id = timeBucket + Const.ID_SPLIT + serviceReferenceMetric.getFrontServiceId() + Const.ID_SPLIT + serviceReferenceMetric.getBehindServiceId() + Const.ID_SPLIT + serviceReferenceMetric.getSourceValue();
 
             serviceReferenceMetric.setId(id);
             serviceReferenceMetric.setTimeBucket(timeBucket);
@@ -168,7 +168,7 @@ public class ServiceReferenceMetricSpanListener implements FirstSpanListener, En
                 serviceReferenceMetric.setFrontServiceId(Const.NONE_SERVICE_ID);
             }
 
-            String id = timeBucket + Const.ID_SPLIT + serviceReferenceMetric.getFrontServiceId() + Const.ID_SPLIT + serviceReferenceMetric.getBehindServiceId();
+            String id = timeBucket + Const.ID_SPLIT + serviceReferenceMetric.getFrontServiceId() + Const.ID_SPLIT + serviceReferenceMetric.getBehindServiceId() + Const.ID_SPLIT + serviceReferenceMetric.getSourceValue();
             serviceReferenceMetric.setId(id);
             serviceReferenceMetric.setTimeBucket(timeBucket);