[Hotfix][Connector-V2][File] Fix ParquetReadStrategy get NPE (#3122)

harveyyue · web-flow · commit ba99de08c825 · 2022-10-18T10:01:47.000+08:00
diff --git a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ParquetReadStrategy.java b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ParquetReadStrategy.java
@@ -114,6 +114,9 @@ public void read(String path, Collector<SeaTunnelRow> output) throws Exception {
     }
 
     private Object resolveObject(Object field, SeaTunnelDataType<?> fieldType) {
+        if (field == null) {
+            return null;
+        }
         switch (fieldType.getSqlType()) {
             case ARRAY:
                 ArrayList<Object> origArray = new ArrayList<>();

Original file line number	Diff line number	Diff line change
`@@ -114,6 +114,9 @@ public void read(String path, Collector<SeaTunnelRow> output) throws Exception {`
`114`	`114`	`}`
`115`	`115`
`116`	`116`	`private Object resolveObject(Object field, SeaTunnelDataType<?> fieldType) {`
	`117`	`+ if (field == null) {`
	`118`	`+ return null;`
	`119`	`+ }`
`117`	`120`	`switch (fieldType.getSqlType()) {`
`118`	`121`	`case ARRAY:`
`119`	`122`	`ArrayList<Object> origArray = new ArrayList<>();`