[INLONG-9995][Manager] Fix error

apache · Apr 17, 2024 · 9943313 · 9943313
1 parent 90b5d0a
commit 9943313
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...service/src/main/java/org/apache/inlong/manager/service/datatype/CsvDataTypeOperator.java b/...service/src/main/java/org/apache/inlong/manager/service/datatype/CsvDataTypeOperator.java
@@ -46,11 +46,10 @@ public List<FieldInfo> parseFields(String str, InlongStreamInfo streamInfo) thro
                 separator = (char) Integer.parseInt(streamInfo.getDataSeparator());
             }
             String[] bodys = StringUtils.split(str, separator);
-            if (bodys.length != fields.size()) {
-                return fields;
-            }
             for (int i = 0; i < bodys.length; i++) {
-                fields.get(i).setFieldValue(bodys[i]);
+                if (i < fields.size()) {
+                    fields.get(i).setFieldValue(bodys[i]);
+                }
             }
         } catch (Exception e) {
             log.warn("parse fields failed for groupId = {}, streamId = {}", streamInfo.getInlongGroupId(),