Mongo operationType NPE prevention (hazelcast#25760)

ahmetmircik · Oct 19, 2023 · ac3862e · ac3862e
1 parent 5533b5f
commit ac3862e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...l/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/SelectProcessorSupplier.java b/...l/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/SelectProcessorSupplier.java
@@ -182,7 +182,7 @@ private JetSqlRow convertStreamDocToRow(ChangeStreamDocument<Document> changeStr
                 row[index] = fromDoc;
             }
         }
-        addIfInProjection(changeStreamDocument.getOperationType().getValue(), "operationType", row);
+        addIfInProjection(changeStreamDocument.getOperationTypeString(), "operationType", row);
         addIfInProjection(changeStreamDocument.getResumeToken().toString(), "resumeToken", row);
         addIfInProjection(LocalDateTime.ofInstant(Instant.ofEpochMilli(ts), systemDefault()), "ts", row);
         addIfInProjection(bsonDateTimeToLocalDateTime(changeStreamDocument.getWallTime()), "wallTime", row);