From 29dcda45937a5ba4a78d4a7cb58cd8cbe1419272 Mon Sep 17 00:00:00 2001 From: OT-XY Date: Fri, 17 Feb 2023 13:47:50 +0800 Subject: [PATCH] [hotfix-#1512][mongodb] Fix the bug that mongodb supports constants --- .../mongodb/converter/MongodbColumnConverter.java | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) diff --git a/chunjun-connectors/chunjun-connector-mongodb/src/main/java/com/dtstack/chunjun/connector/mongodb/converter/MongodbColumnConverter.java b/chunjun-connectors/chunjun-connector-mongodb/src/main/java/com/dtstack/chunjun/connector/mongodb/converter/MongodbColumnConverter.java index 6066f2cdf6..053dc6200e 100644 --- a/chunjun-connectors/chunjun-connector-mongodb/src/main/java/com/dtstack/chunjun/connector/mongodb/converter/MongodbColumnConverter.java +++ b/chunjun-connectors/chunjun-connector-mongodb/src/main/java/com/dtstack/chunjun/connector/mongodb/converter/MongodbColumnConverter.java @@ -99,17 +99,13 @@ protected MongoSerializationConverter wrapIntoNullableMongodbExternalConverter( public RowData toInternal(Document document) { List fieldList = commonConf.getColumn(); ColumnRowData result = new ColumnRowData(fieldList.size()); - int convertIndex = 0; - for (FieldConf fieldConf : fieldList) { + for (int i = 0; i < fieldList.size(); i++) { AbstractBaseColumn baseColumn = null; - if (StringUtils.isNullOrWhitespaceOnly(fieldConf.getValue())) { - Object field = document.get(fieldConf.getName()); - baseColumn = - (AbstractBaseColumn) - toInternalConverters.get(convertIndex).deserialize(field); - convertIndex++; + if (StringUtils.isNullOrWhitespaceOnly(fieldList.get(i).getValue())) { + Object field = document.get(fieldList.get(i).getName()); + baseColumn = (AbstractBaseColumn) toInternalConverters.get(i).deserialize(field); } - result.addField(assembleFieldProps(fieldConf, baseColumn)); + result.addField(assembleFieldProps(fieldList.get(i), baseColumn)); } return result; }