This is an automated email from the ASF dual-hosted git repository.

qiaojialin pushed a commit to branch rel/1.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/1.1 by this push:
     new b2f42e475a8  [IOTDB-5819] Fix npe when booting net metrics (#9698) 
(#10085)
b2f42e475a8 is described below

commit b2f42e475a83c70f28af71f22dc7e8c9206676c1
Author: Potato <[email protected]>
AuthorDate: Thu Jun 8 20:25:27 2023 +0800

     [IOTDB-5819] Fix npe when booting net metrics (#9698) (#10085)
---
 .../java/org/apache/iotdb/metrics/metricsets/net/NetMetrics.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/NetMetrics.java
 
b/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/NetMetrics.java
index e1e565c049c..55befc242c0 100644
--- 
a/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/NetMetrics.java
+++ 
b/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/NetMetrics.java
@@ -48,7 +48,7 @@ public class NetMetrics implements IMetricSet {
           RECEIVED_BYTES,
           MetricLevel.IMPORTANT,
           netMetricManager,
-          x -> x.getReceivedByte().get(iface),
+          x -> x.getReceivedByte().getOrDefault(iface, 0L).doubleValue(),
           TYPE,
           RECEIVE,
           IFACE_NAME,
@@ -57,7 +57,7 @@ public class NetMetrics implements IMetricSet {
           TRANSMITTED_BYTES,
           MetricLevel.IMPORTANT,
           netMetricManager,
-          x -> x.getTransmittedBytes().get(iface),
+          x -> x.getTransmittedBytes().getOrDefault(iface, 0L).doubleValue(),
           TYPE,
           TRANSMIT,
           IFACE_NAME,
@@ -66,7 +66,7 @@ public class NetMetrics implements IMetricSet {
           RECEIVED_PACKETS,
           MetricLevel.IMPORTANT,
           netMetricManager,
-          x -> x.getReceivedPackets().get(iface),
+          x -> x.getReceivedPackets().getOrDefault(iface, 0L).doubleValue(),
           TYPE,
           RECEIVE,
           IFACE_NAME,
@@ -75,7 +75,7 @@ public class NetMetrics implements IMetricSet {
           TRANSMITTED_PACKETS,
           MetricLevel.IMPORTANT,
           netMetricManager,
-          x -> x.getTransmittedPackets().get(iface),
+          x -> x.getTransmittedPackets().getOrDefault(iface, 0L).doubleValue(),
           TYPE,
           TRANSMIT,
           IFACE_NAME,

Reply via email to