commit bfd18f9b14f3b499a5ba4f55cf7f2ada58ca3114
author kishoreg <g.kishore@gmail.com> Thu Jul 28 08:46:33 2022 -0700
committer kishoreg <g.kishore@gmail.com> Thu Jul 28 08:46:33 2022 -0700
tree c39633a3f90338e41a37b24b5ca18f13bd6727c9
parent b52d0659b6278d4aba8ce86ef33c40ea16f16584

adding null check for row metadata

pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java

diff --git a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java
index 2629a81..d95b02c 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java
@@ -530,7 +530,7 @@
           .decode(messagesAndOffsets.getMessageAtIndex(index),
               messagesAndOffsets.getMessageOffsetAtIndex(index),
               messagesAndOffsets.getMessageLengthAtIndex(index), reuse);
-      if (msgMetadata.getHeaders() != null) {
+      if (msgMetadata != null && msgMetadata.getHeaders() != null) {
         for (Map.Entry<String, Object> entrySet : msgMetadata.getHeaders().getFieldToValueMap().entrySet()) {
           decodedRow.putValue("header$" + entrySet.getKey(), entrySet.getValue());
         }