[mongodb][hotfix] Fix NullPointerException when executing ddl operation in MongoDB (#2107)

Co-authored-by: Jiabao Sun <jiabao.sun@xtransfer.cn>
pull/2203/head
emhui 2 years ago committed by GitHub
parent bb60bfede4
commit 7cdeb0d776
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -124,10 +124,9 @@ public class MongoDBConnectorDeserializationSchema
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);

Loading…
Cancel
Save