diff --git a/oap-server/server-receiver-plugin/skywalking-jvm-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/jvm/provider/handler/JVMSourceDispatcher.java b/oap-server/server-receiver-plugin/skywalking-jvm-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/jvm/provider/handler/JVMSourceDispatcher.java index 51aa69ffd01be0988656926c9304956667c560d5..3d41f69015f2a7636cd699d4f61a87d7e72d7f0f 100644 --- a/oap-server/server-receiver-plugin/skywalking-jvm-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/jvm/provider/handler/JVMSourceDispatcher.java +++ b/oap-server/server-receiver-plugin/skywalking-jvm-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/jvm/provider/handler/JVMSourceDispatcher.java @@ -18,7 +18,7 @@ package org.apache.skywalking.oap.server.receiver.jvm.provider.handler; -import java.util.List; +import java.util.*; import org.apache.skywalking.apm.network.common.CPU; import org.apache.skywalking.apm.network.language.agent.*; import org.apache.skywalking.oap.server.core.*; @@ -45,7 +45,7 @@ public class JVMSourceDispatcher { void sendMetric(int serviceInstanceId, long minuteTimeBucket, JVMMetric metric) { ServiceInstanceInventory serviceInstanceInventory = instanceInventoryCache.get(serviceInstanceId); int serviceId; - if (serviceInstanceInventory == null) { + if (Objects.nonNull(serviceInstanceInventory)) { serviceId = serviceInstanceInventory.getServiceId(); } else { logger.warn("Can't found service by service instance id from cache, service instance id is: {}", serviceInstanceId); @@ -93,7 +93,8 @@ public class JVMSourceDispatcher { }); } - private void sendToMemoryMetricProcess(int serviceId, int serviceInstanceId, long timeBucket, List memories) { + private void sendToMemoryMetricProcess(int serviceId, int serviceInstanceId, long timeBucket, + List memories) { memories.forEach(memory -> { ServiceInstanceJVMMemory serviceInstanceJVMMemory = new ServiceInstanceJVMMemory(); serviceInstanceJVMMemory.setId(serviceInstanceId);