voonhous opened a new issue, #13994:
URL: https://github.com/apache/hudi/issues/13994

   ### Bug Description
   
   **What happened:**
   Table is not readable when Hudi table of version 8 has a non-empty archived 
LSM timeline.
   
   **What you expected:**
   Reads should not throw an error, table rows should be returned.
   
   **Steps to reproduce:**
   1. Table version 8
   2. Non-empty archived timeline
   3. Any table type
   4. Perform a normal read
   
   
   ### Environment
   
   **Hudi version:** 1.0.2
   **Query engine:** Trino
   **Relevant configs:**
   Table version 8 with a non-empty archived tiemline
   
   ### Logs and Stack Trace
   
   error thrown:
   ```
   Caused by: java.lang.UnsupportedOperationException: 
HudiTrinoFileReaderFactory does not support Parquet file reader
        at 
io.trino.plugin.hudi.io.HudiTrinoFileReaderFactory.newParquetFileReader(HudiTrinoFileReaderFactory.java:39)
        at 
org.apache.hudi.io.storage.HoodieFileReaderFactory.getFileReader(HoodieFileReaderFactory.java:70)
        at 
org.apache.hudi.io.storage.HoodieFileReaderFactory.getFileReader(HoodieFileReaderFactory.java:50)
        at 
org.apache.hudi.common.table.timeline.versioning.v2.ArchivedTimelineLoaderV2.lambda$loadInstants$1(ArchivedTimelineLoaderV2.java:66)
        at 
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:186)
        at 
java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:197)
        at 
java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1716)
        at 
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:570)
        at 
java.base/java.util.stream.ForEachOps$ForEachTask.compute(ForEachOps.java:293)
        at 
java.base/java.util.concurrent.CountedCompleter.exec(CountedCompleter.java:759)
        at 
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:507)
        at 
java.base/java.util.concurrent.ForkJoinTask.invoke(ForkJoinTask.java:676)
        at 
java.base/java.util.stream.ForEachOps$ForEachOp.evaluateParallel(ForEachOps.java:162)
        at 
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateParallel(ForEachOps.java:176)
        at 
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:264)
        at 
java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:636)
        at 
org.apache.hudi.common.table.timeline.versioning.v2.ArchivedTimelineLoaderV2.loadInstants(ArchivedTimelineLoaderV2.java:62)
        at 
org.apache.hudi.common.table.timeline.versioning.v2.CompletionTimeQueryViewV2.load(CompletionTimeQueryViewV2.java:313)
        at 
org.apache.hudi.common.table.timeline.versioning.v2.CompletionTimeQueryViewV2.<init>(CompletionTimeQueryViewV2.java:108)
        at 
org.apache.hudi.common.table.timeline.versioning.v2.CompletionTimeQueryViewV2.<init>(CompletionTimeQueryViewV2.java:93)
        at 
org.apache.hudi.common.table.timeline.versioning.v2.TimelineV2Factory.createCompletionTimeQueryView(TimelineV2Factory.java:79)
        at 
org.apache.hudi.common.table.view.AbstractTableFileSystemView.init(AbstractTableFileSystemView.java:127)
        at 
org.apache.hudi.common.table.view.HoodieTableFileSystemView.init(HoodieTableFileSystemView.java:128)
        at 
org.apache.hudi.common.table.view.HoodieTableFileSystemView.<init>(HoodieTableFileSystemView.java:122)
        at 
org.apache.hudi.common.table.view.HoodieTableFileSystemView.<init>(HoodieTableFileSystemView.java:102)
        at io.trino.plugin.hudi.HudiUtil.getFileSystemView(HudiUtil.java:384)
        at 
io.trino.plugin.hudi.query.HudiSnapshotDirectoryLister.lambda$new$0(HudiSnapshotDirectoryLister.java:57)
        at org.apache.hudi.util.Lazy.get(Lazy.java:54)
        at 
io.trino.plugin.hudi.query.HudiSnapshotDirectoryLister.listStatus(HudiSnapshotDirectoryLister.java:74)
        at 
io.trino.plugin.hudi.partition.HudiPartitionInfoLoader.generateSplitsFromPartition(HudiPartitionInfoLoader.java:71)
        at 
io.trino.plugin.hudi.partition.HudiPartitionInfoLoader.run(HudiPartitionInfoLoader.java:63)
        at 
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:545)
        at 
com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131)
        at 
com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:75)
        ... 5 more
   ```
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to