Skip to content

Commit

Permalink
[fix] support the data source field is less than the target (Hive) fi…
Browse files Browse the repository at this point in the history
…eld,it will throw null pointer exception(apache#8150)
  • Loading branch information
linjc13 committed Dec 4, 2024
1 parent d33b0da commit 0dde290
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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)) {
Expand Down

0 comments on commit 0dde290

Please sign in to comment.