Add null check to prevent initialization NPE for byteOutMetric in Psc…

…Writer
pinterest · Oct 30, 2024 · 8be3077 · 8be3077
1 parent 11feb61
commit 8be3077
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/psc-flink/src/main/java/com/pinterest/flink/connector/psc/sink/PscWriter.java b/psc-flink/src/main/java/com/pinterest/flink/connector/psc/sink/PscWriter.java
@@ -430,6 +430,9 @@ private void registerMetricSync() {
                     if (closed) {
                         return;
                     }
+                    if (byteOutMetric == null || byteOutMetric.metricValue() == null) {
+                        return;
+                    }
                     long outgoingBytesUntilNow = ((Number) byteOutMetric.metricValue()).longValue();
                     long outgoingBytesSinceLastUpdate =
                             outgoingBytesUntilNow - latestOutgoingByteTotal;