Application reference metric and application metric test ok.

apm-collector/apm-collector-analysis/analysis-metric/metric-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/metric/provider/worker/application/ApplicationMetricAggregationWorker.java

@@ -42,8 +42,14 @@ public class ApplicationMetricAggregationWorker extends AggregationWorker<Applic
     @Override protected ApplicationMetric transform(ApplicationReferenceMetric applicationReferenceMetric) {
         Integer applicationId = applicationReferenceMetric.getBehindApplicationId();
         Long timeBucket = applicationReferenceMetric.getTimeBucket();
-        ApplicationMetric applicationMetric = new ApplicationMetric(String.valueOf(timeBucket) + Const.ID_SPLIT + String.valueOf(applicationId));
+
+        String id = String.valueOf(timeBucket)
+            + Const.ID_SPLIT + String.valueOf(applicationId)
+            + Const.ID_SPLIT + applicationReferenceMetric.getSourceValue();
+
+        ApplicationMetric applicationMetric = new ApplicationMetric(id);
         applicationMetric.setApplicationId(applicationId);
+        applicationMetric.setSourceValue(applicationReferenceMetric.getSourceValue());
 
         applicationMetric.setTransactionCalls(applicationReferenceMetric.getTransactionCalls());
         applicationMetric.setTransactionDurationSum(applicationReferenceMetric.getTransactionDurationSum());

apm-collector/apm-collector-analysis/analysis-metric/metric-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/metric/provider/worker/application/ApplicationReferenceMetricAggregationWorker.java

@@ -53,11 +53,15 @@ public class ApplicationReferenceMetricAggregationWorker extends AggregationWork
         Integer frontApplicationId = instanceCacheService.getApplicationId(instanceReferenceMetric.getFrontInstanceId());
         Integer behindApplicationId = instanceCacheService.getApplicationId(instanceReferenceMetric.getBehindInstanceId());
 
-        String id = instanceReferenceMetric.getTimeBucket() + Const.ID_SPLIT + frontApplicationId + Const.ID_SPLIT + behindApplicationId;
+        String id = instanceReferenceMetric.getTimeBucket()
+            + Const.ID_SPLIT + frontApplicationId
+            + Const.ID_SPLIT + behindApplicationId
+            + Const.ID_SPLIT + instanceReferenceMetric.getSourceValue();
 
         ApplicationReferenceMetric applicationReferenceMetric = new ApplicationReferenceMetric(id);
         applicationReferenceMetric.setFrontApplicationId(frontApplicationId);
         applicationReferenceMetric.setBehindApplicationId(behindApplicationId);
+        applicationReferenceMetric.setSourceValue(instanceReferenceMetric.getSourceValue());
 
         applicationReferenceMetric.setTransactionCalls(instanceReferenceMetric.getTransactionCalls());
         applicationReferenceMetric.setTransactionErrorCalls(instanceReferenceMetric.getTransactionErrorCalls());