fix NPE

apache · Jan 22, 2025 · d8f9788 · d8f9788
1 parent 05852d8
commit d8f9788
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...n/java/org/apache/iotdb/db/subscription/event/pipe/SubscriptionPipeTabletBatchEvents.java b/...n/java/org/apache/iotdb/db/subscription/event/pipe/SubscriptionPipeTabletBatchEvents.java
@@ -24,6 +24,7 @@
 import org.apache.iotdb.db.subscription.event.batch.SubscriptionPipeTabletEventBatch;
 
 import java.util.List;
+import java.util.Objects;
 import java.util.stream.Collectors;
 
 import static com.google.common.base.MoreObjects.toStringHelper;
@@ -72,6 +73,9 @@ public String toString() {
 
   private static String formatEnrichedEvents(
       final List<EnrichedEvent> enrichedEvents, final int threshold) {
+    if (Objects.isNull(enrichedEvents) || enrichedEvents.isEmpty()) {
+      return "";
+    }
     final List<String> eventMessageList =
         enrichedEvents.stream()
             .limit(threshold)