projects / hudi.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 672974c) | patch
[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
tree52f232895b6de81822dd3ac7a5fd8ab1988c3b94tree | snapshot
parent672974c4129135eac6e9d62dd23cc5d3e7a10863commit | diff
[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 diff | blob | history
hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestHoodieLogFileCommand.java diff | blob | history
hudi-common/src/main/java/org/apache/hudi/common/fs/FSUtils.java diff | blob | history
hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java diff | blob | history
hudi-examples/hudi-examples-flink/src/test/java/org/apache/hudi/examples/quickstart/TestQuickstartData.java diff | blob | history
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FormatUtils.java diff | blob | history
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestData.java diff | blob | history
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeCompactedRecordReader.java diff | blob | history
Upserts, Deletes And Incremental Processing on Big Data.