diff --git a/rition-center/service/collector/src/main/java/rition/service/collector/MetricCollectingService.java b/rition-center/service/collector/src/main/java/rition/service/collector/MetricCollectingService.java index cec5ed7..fc33772 100644 --- a/rition-center/service/collector/src/main/java/rition/service/collector/MetricCollectingService.java +++ b/rition-center/service/collector/src/main/java/rition/service/collector/MetricCollectingService.java @@ -61,7 +61,8 @@ public class MetricCollectingService { public void receiveData(Map> collectedMetricData) { List batchSaveEntityList = new ArrayList<>(DEFAULT_DB_BATCH_SIZE); int turn = 0; - for (Long timestamp : collectedMetricData.keySet()) { + List sortedTime = collectedMetricData.keySet().stream().sorted().toList(); + for (Long timestamp : sortedTime) { Map instanceMetricData = collectedMetricData.get(timestamp); for (String instanceId : instanceMetricData.keySet()) { MetricDataDto metricDataDto = instanceMetricData.get(instanceId);