From 0dde29038f0c0ed35b488c3b9ffd7b89dae03b7c Mon Sep 17 00:00:00 2001 From: linjc13 Date: Wed, 4 Dec 2024 17:33:27 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=20support=20the=20data=20source=20field?= =?UTF-8?q?=20is=20less=20than=20the=20target=20(Hive)=20field=EF=BC=8Cit?= =?UTF-8?q?=20will=20throw=20null=20pointer=20exception(#8150)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../connectors/seatunnel/file/sink/config/FileSinkConfig.java | 1 + 1 file changed, 1 insertion(+) diff --git a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSinkConfig.java b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSinkConfig.java index 577b62defbf2..d9315a6f5cd1 100644 --- a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSinkConfig.java +++ b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSinkConfig.java @@ -187,6 +187,7 @@ public FileSinkConfig(@NonNull Config config, @NonNull SeaTunnelRowType seaTunne this.sinkColumnsIndexInRow = this.sinkColumnList.stream() .map(column -> columnsMap.get(column.toLowerCase())) + .filter(e -> e != null) .collect(Collectors.toList()); if (!CollectionUtils.isEmpty(this.partitionFieldList)) {