[ 
https://issues.apache.org/jira/browse/HUDI-6624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

hehuiyuan updated HUDI-6624:
----------------------------
    Description: 
```java
org.apache.flink.runtime.rest.handler.RestHandlerException: The main method 
caused an error: java.util.NoSuchElementException: No value present in Option
    at org.apache.hudi.common.util.Option.get(Option.java:89)
    at 
org.apache.hudi.table.HoodieTableSource.buildFileIndex(HoodieTableSource.java:341)
    at 
org.apache.hudi.table.HoodieTableSource.getBatchInputFormat(HoodieTableSource.java:381)
    at 
org.apache.hudi.table.HoodieTableSource.getInputFormat(HoodieTableSource.java:366)
    at 
org.apache.hudi.table.HoodieTableSource.getInputFormat(HoodieTableSource.java:361)
    at 
org.apache.hudi.table.HoodieTableSource$1.produceDataStream(HoodieTableSource.java:198)
    at 
org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.translateToPlanInternal(CommonExecTableSourceScan.java:106)
    at 
org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecTableSourceScan.translateToPlanInternal(BatchExecTableSourceScan.java:49)
    at 
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:134)
    at 
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:250)
```

 

 

  was:
```java
org.apache.flink.runtime.rest.handler.RestHandlerException: The main method 
caused an error: java.util.NoSuchElementException: No value present in Option
    at org.apache.hudi.common.util.Option.get(Option.java:89)
    at 
org.apache.hudi.table.HoodieTableSource.buildFileIndex(HoodieTableSource.java:341)
    at 
org.apache.hudi.table.HoodieTableSource.getBatchInputFormat(HoodieTableSource.java:381)
    at 
org.apache.hudi.table.HoodieTableSource.getInputFormat(HoodieTableSource.java:366)
    at 
org.apache.hudi.table.HoodieTableSource.getInputFormat(HoodieTableSource.java:361)
    at 
org.apache.hudi.table.HoodieTableSource$1.produceDataStream(HoodieTableSource.java:198)
    at 
org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.translateToPlanInternal(CommonExecTableSourceScan.java:106)
    at 
org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecTableSourceScan.translateToPlanInternal(BatchExecTableSourceScan.java:49)
    at 
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:134)
    at 
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:250)
```

        Summary: Return Empty split input array  when there is no commit 
instant for batch read  (was: 1)

> Return Empty split input array  when there is no commit instant for batch read
> ------------------------------------------------------------------------------
>
>                 Key: HUDI-6624
>                 URL: https://issues.apache.org/jira/browse/HUDI-6624
>             Project: Apache Hudi
>          Issue Type: Bug
>            Reporter: hehuiyuan
>            Priority: Major
>
> ```java
> org.apache.flink.runtime.rest.handler.RestHandlerException: The main method 
> caused an error: java.util.NoSuchElementException: No value present in Option
>     at org.apache.hudi.common.util.Option.get(Option.java:89)
>     at 
> org.apache.hudi.table.HoodieTableSource.buildFileIndex(HoodieTableSource.java:341)
>     at 
> org.apache.hudi.table.HoodieTableSource.getBatchInputFormat(HoodieTableSource.java:381)
>     at 
> org.apache.hudi.table.HoodieTableSource.getInputFormat(HoodieTableSource.java:366)
>     at 
> org.apache.hudi.table.HoodieTableSource.getInputFormat(HoodieTableSource.java:361)
>     at 
> org.apache.hudi.table.HoodieTableSource$1.produceDataStream(HoodieTableSource.java:198)
>     at 
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.translateToPlanInternal(CommonExecTableSourceScan.java:106)
>     at 
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecTableSourceScan.translateToPlanInternal(BatchExecTableSourceScan.java:49)
>     at 
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:134)
>     at 
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:250)
> ```
>  
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to