kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed a logical error cause JVM metrics not dispatched. (#2398)

This commit is contained in:
彭勇升 pengys 2019-03-23 23:40:35 +08:00 committed by 吴晟 Wu Sheng
parent cea04f3ca0
commit f38aea3d97
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
oap-server/server-receiver-plugin/skywalking-jvm-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/jvm/provider/handler/JVMSourceDispatcher.java
View File

@ -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<Memory> memories) {
private void sendToMemoryMetricProcess(int serviceId, int serviceInstanceId, long timeBucket,
List<Memory> memories) {
memories.forEach(memory -> {
ServiceInstanceJVMMemory serviceInstanceJVMMemory = new ServiceInstanceJVMMemory();
serviceInstanceJVMMemory.setId(serviceInstanceId);