modify whether is NULL for bsonType ,for issue:datavane/tis#455

baisui1981 · baisui1981 · commit d76b12255c16 · 2025-07-16T23:56:34.000+08:00
diff --git a/tis-datax/tis-datax-mongodb-plugin/src/main/java/com/qlangtech/tis/plugin/datax/mongo/MongoColValGetter.java b/tis-datax/tis-datax-mongodb-plugin/src/main/java/com/qlangtech/tis/plugin/datax/mongo/MongoColValGetter.java
@@ -61,7 +61,7 @@ public FlinkPropValGetter(MongoCMeta cmeta, ZoneId zone) {
         @Override
         public Object apply(BsonDocument document) {
             BsonValue val = cmeta.getBsonVal(document);
-            if (val == null || (val.getBsonType() == BsonType.NULL)) {
+            if (val == null ||  (val.getBsonType() == BsonType.NULL)) {
                 return null;
             }
             return MongoDataXColUtils.createCol(cmeta, val, false, zone);

Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,7 @@ public FlinkPropValGetter(MongoCMeta cmeta, ZoneId zone) {`
`61`	`61`	`@Override`
`62`	`62`	`public Object apply(BsonDocument document) {`
`63`	`63`	`BsonValue val = cmeta.getBsonVal(document);`
`64`		`- if (val == null \|\| (val.getBsonType() == BsonType.NULL)) {`
	`64`	`+ if (val == null \|\| (val.getBsonType() == BsonType.NULL)) {`
`65`	`65`	`return null;`
`66`	`66`	`}`
`67`	`67`	`return MongoDataXColUtils.createCol(cmeta, val, false, zone);`