lw_wei created HUDI-6280:
----------------------------
Summary: Flink use Hudi-sink by MOR report an NullPoint Error
Key: HUDI-6280
URL: https://issues.apache.org/jira/browse/HUDI-6280
Project: Apache Hudi
Issue Type: Bug
Reporter: lw_wei
Flink version: 1.16.0
hudi version: hudi-flink1.16-bundle : 0.13.0
I set the tableType is MOR.
I Found one bug:
In file 'org.apache.hudi.common.table.view.AbstractTableFileSystemView.java',
in Method 'ensurePartitionLoadedCorrectly',
1). line 425 : 'FileStatus[] statuses = listPartition(partitionPath)'. This
method when the partitionPath is not exists in HDFS, you just return 'new
FileStatus[0]', and not create partitionPath in the HDFS.
2). line 429 : 'List<HoodieFileGroup> groups = addFilesToView(statuses)', in
this method will 'buildFileGroups' use the 'FileStatus', but when execute
'fileStatus.getPath().getName()', will got an NullPoint Exception
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
