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));
               }

Reply via email to