[mongodb][hotfix] Fix NullPointerException when executing ddl operati…

…on in MongoDB (apache#2107) Co-authored-by: Jiabao Sun <jiabao.sun@xtransfer.cn>
Jiabao-Sun · Jun 12, 2023 · 7cdeb0d · 7cdeb0d
1 parent bb60bfe
commit 7cdeb0d
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...ava/com/ververica/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java b/...ava/com/ververica/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java
@@ -124,10 +124,9 @@ public void deserialize(SourceRecord record, Collector<RowData> out) throws Exce
         Schema valueSchema = record.valueSchema();
 
         OperationType op = operationTypeFor(record);
+
         BsonDocument documentKey =
-                checkNotNull(
-                        extractBsonDocument(
-                                value, valueSchema, MongoDBEnvelope.DOCUMENT_KEY_FIELD));
+                extractBsonDocument(value, valueSchema, MongoDBEnvelope.DOCUMENT_KEY_FIELD);
         BsonDocument fullDocument =
                 extractBsonDocument(value, valueSchema, MongoDBEnvelope.FULL_DOCUMENT_FIELD);