[HUDI-3454] Fix partition name in all code paths for LogRecordScanner (#5252)
authorSagar Sumit <sagarsumit09@gmail.com>
Fri, 8 Apr 2022 04:29:36 +0000 (09:59 +0530)
committerGitHub <noreply@github.com>
Fri, 8 Apr 2022 04:29:36 +0000 (09:59 +0530)
commitdf87095ef03b73b779bcddb65b7ac372686eade2
tree52f232895b6de81822dd3ac7a5fd8ab1988c3b94
parent672974c4129135eac6e9d62dd23cc5d3e7a10863
[HUDI-3454] Fix partition name in all code paths for LogRecordScanner (#5252)

* Depend on FSUtils#getRelativePartitionPath(basePath, logFilePath.getParent)
to get the partition.

* If the list of log file paths in the split is empty, then fallback to usual behaviour.
hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieLogFileCommand.java
hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestHoodieLogFileCommand.java
hudi-common/src/main/java/org/apache/hudi/common/fs/FSUtils.java
hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java
hudi-examples/hudi-examples-flink/src/test/java/org/apache/hudi/examples/quickstart/TestQuickstartData.java
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FormatUtils.java
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestData.java
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeCompactedRecordReader.java