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; }