This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new a0dae41 [HUDI-2758] remove redundant code in the
hoodieRealtimeInputFormatUitls.getRealtimeSplits (#3994)
a0dae41 is described below
commit a0dae41409a4f2d509aae1b16a4b509ec774c454
Author: xiarixiaoyao <[email protected]>
AuthorDate: Mon Nov 15 11:29:40 2021 +0800
[HUDI-2758] remove redundant code in the
hoodieRealtimeInputFormatUitls.getRealtimeSplits (#3994)
---
.../org/apache/hudi/hadoop/utils/HoodieRealtimeInputFormatUtils.java | 4 ----
1 file changed, 4 deletions(-)
diff --git
a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieRealtimeInputFormatUtils.java
b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieRealtimeInputFormatUtils.java
index 9140969..11ce0a6 100644
---
a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieRealtimeInputFormatUtils.java
+++
b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieRealtimeInputFormatUtils.java
@@ -125,10 +125,6 @@ public class HoodieRealtimeInputFormatUtils extends
HoodieInputFormatUtils {
if (split instanceof BootstrapBaseFileSplit) {
BootstrapBaseFileSplit eSplit = (BootstrapBaseFileSplit) split;
rtSplits.add(createRealtimeBoostrapBaseFileSplit(eSplit,
metaClient.getBasePath(), logFilePaths, maxCommitTime));
- } else if (split instanceof BaseFileWithLogsSplit) {
- BaseFileWithLogsSplit bs = (BaseFileWithLogsSplit)split;
- HoodieRealtimeFileSplit hoodieRealtimeFileSplit = new
HoodieRealtimeFileSplit(bs, bs.getBasePath(), bs.getDeltaLogPaths(),
bs.getMaxCommitTime(), finalHoodieVirtualKeyInfo);
- rtSplits.add(hoodieRealtimeFileSplit);
} else {
rtSplits.add(new HoodieRealtimeFileSplit(split,
metaClient.getBasePath(), logFilePaths, maxCommitTime,
finalHoodieVirtualKeyInfo));
}