starrocks 查询 paimon 报错

💬 StarRocks 用户问答
#1

starrocks创建paimon catalog后，可以获取paimon数据库以及表名元数据信息，但是在通过select查询表数据时sr报错：SQL 错误 [1064] [42000]: java.util.concurrent.ExecutionException: java.lang.IndexOutOfBoundsException: Index: 13, Size: 13

image
image991×444 16.7 KB

image
image823×426 12.7 KB

image
image1218×682 40.5 KB

image
image1189×547 20.8 KB

版本方面flink为1.16.1,starrocks为3.1.6，paimon为0.8
麻烦各位老师帮忙指导下

#2

fe日志：
2024-04-22 09:29:44,352 INFO (replayer|103) [GlobalStateMgr.replayJournalInner():2364] replayed journal from 3271866 - 3271867
2024-04-22 09:29:46,125 INFO (nioEventLoopGroup-6-3|140) [RestBaseAction.handleRequest():71] receive http request. url=/metrics
2024-04-22 09:29:47,034 INFO (replayer|103) [GlobalStateMgr.replayJournalInner():2364] replayed journal from 3271867 - 3271868
2024-04-22 09:29:49,354 INFO (nioEventLoopGroup-6-67|383) [RestBaseAction.handleRequest():71] receive http request. url=/api/bootstrap?cluster_id=1&token=b8f0f444-c07f-448f-8572-39ac262658c3
2024-04-22 09:29:49,359 INFO (replayer|103) [GlobalStateMgr.replayJournalInner():2364] replayed journal from 3271868 - 3271869
2024-04-22 09:29:51,503 INFO (starrocks-mysql-nio-pool-18|41158) [MetadataMgr$QueryMetadatas.getConnectorMetadata():389] Succeed to register query level connector metadata [catalog:paimon_catalog, queryId: d0a692a2-0047-11ef-9f9a-80615f1c5bdc]
2024-04-22 09:29:51,634 ERROR (starrocks-mysql-nio-pool-18|41158) [MetadataMgr.getRemoteFileInfos():332] Failed to list remote file’s metadata on catalog [paimon_catalog], table [Table [id=100000465, name=quanll_ipfix_test, type=PAIMON]]
java.lang.RuntimeException: java.util.concurrent.ExecutionException: java.lang.IndexOutOfBoundsException: Index: 13, Size: 13
at org.apache.paimon.utils.ParallellyExecuteUtils$1.advanceIfNeeded(ParallellyExecuteUtils.java:82) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.utils.ParallellyExecuteUtils$1.hasNext(ParallellyExecuteUtils.java:57) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.manifest.ManifestEntry.mergeEntries(ManifestEntry.java:123) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.manifest.ManifestEntry.mergeEntries(ManifestEntry.java:117) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.operation.AbstractFileStoreScan.doPlan(AbstractFileStoreScan.java:245) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.operation.AbstractFileStoreScan.plan(AbstractFileStoreScan.java:192) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.table.source.snapshot.SnapshotReaderImpl.read(SnapshotReaderImpl.java:179) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.table.source.snapshot.FullStartingScanner.scan(FullStartingScanner.java:41) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.table.source.InnerTableScanImpl.plan(InnerTableScanImpl.java:62) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.table.source.InnerTableScanImpl.plan(InnerTableScanImpl.java:29) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at com.starrocks.connector.paimon.PaimonMetadata.getRemoteFileInfos(PaimonMetadata.java:195) ~[starrocks-fe.jar:?]
at com.starrocks.server.MetadataMgr.getRemoteFileInfos(MetadataMgr.java:329) ~[starrocks-fe.jar:?]
at com.starrocks.connector.paimon.PaimonMetadata.getTableStatistics(PaimonMetadata.java:222) ~[starrocks-fe.jar:?]
at com.starrocks.server.MetadataMgr.lambda$getTableStatistics$5(MetadataMgr.java:316) ~[starrocks-fe.jar:?]
at java.util.Optional.map(Optional.java:215) ~[?:1.8.0_352]
at com.starrocks.server.MetadataMgr.getTableStatistics(MetadataMgr.java:315) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.computePaimonScanNode(StatisticsCalculator.java:368) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.visitLogicalPaimonScan(StatisticsCalculator.java:356) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.visitLogicalPaimonScan(StatisticsCalculator.java:159) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.logical.LogicalPaimonScanOperator.accept(LogicalPaimonScanOperator.java:47) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.estimatorStats(StatisticsCalculator.java:175) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.task.DeriveStatsTask.execute(DeriveStatsTask.java:57) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.task.SeriallyTaskScheduler.executeTasks(SeriallyTaskScheduler.java:69) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.memoOptimize(Optimizer.java:595) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.optimizeByCost(Optimizer.java:201) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.optimize(Optimizer.java:134) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.createQueryPlan(StatementPlanner.java:142) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.planQuery(StatementPlanner.java:117) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.plan(StatementPlanner.java:92) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.plan(StatementPlanner.java:57) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.execute(StmtExecutor.java:462) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:366) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.dispatch(ConnectProcessor.java:480) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.processOnce(ConnectProcessor.java:756) ~[starrocks-fe.jar:?]
at com.starrocks.mysql.nio.ReadListener.lambda$handleEvent$0(ReadListener.java:69) ~[starrocks-fe.jar:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_352]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_352]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_352]
Caused by: java.util.concurrent.ExecutionException: java.lang.IndexOutOfBoundsException: Index: 13, Size: 13
at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_352]
at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) ~[?:1.8.0_352]
at org.apache.paimon.utils.ParallellyExecuteUtils$1.advanceIfNeeded(ParallellyExecuteUtils.java:80) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
… 37 more
Caused by: java.lang.IndexOutOfBoundsException: Index: 13, Size: 13
at java.util.ArrayList.rangeCheck(ArrayList.java:659) ~[?:1.8.0_352]
at java.util.ArrayList.get(ArrayList.java:435) ~[?:1.8.0_352]
at org.apache.paimon.format.avro.FieldReaderFactory$RowReader.(FieldReaderFactory.java:455) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory$RowReader.(FieldReaderFactory.java:447) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory.visitRecord(FieldReaderFactory.java:147) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory.visitRecord(FieldReaderFactory.java:44) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroSchemaVisitor.visit(AvroSchemaVisitor.java:41) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory.visitUnion(FieldReaderFactory.java:70) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory.visitUnion(FieldReaderFactory.java:44) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroSchemaVisitor.visit(AvroSchemaVisitor.java:44) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory$RowReader.(FieldReaderFactory.java:456) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory.createRowReader(FieldReaderFactory.java:436) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroRowDatumReader.setSchema(AvroRowDatumReader.java:54) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.shade.org.apache.avro.file.DataFileStream.initialize(DataFileStream.java:145) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.shade.org.apache.avro.file.DataFileReader.(DataFileReader.java:143) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.shade.org.apache.avro.file.DataFileReader.(DataFileReader.java:134) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.shade.org.apache.avro.file.DataFileReader.openReader(DataFileReader.java:74) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroBulkFormat$AvroReader.createReaderFromPath(AvroBulkFormat.java:81) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroBulkFormat$AvroReader.(AvroBulkFormat.java:68) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroBulkFormat$AvroReader.(AvroBulkFormat.java:58) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroBulkFormat.createReader(AvroBulkFormat.java:55) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroBulkFormat.createReader(AvroBulkFormat.java:41) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.utils.FileUtils.createFormatReader(FileUtils.java:128) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.utils.ObjectsFile.read(ObjectsFile.java:97) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.operation.AbstractFileStoreScan.readManifestFileMeta(AbstractFileStoreScan.java:341) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.operation.AbstractFileStoreScan.lambda$null$2(AbstractFileStoreScan.java:238) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:269) ~[?:1.8.0_352]
at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175) ~[?:1.8.0_352]
at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384) ~[?:1.8.0_352]
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) ~[?:1.8.0_352]
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) ~[?:1.8.0_352]
at java.util.stream.ReduceOps$ReduceTask.doLeaf(ReduceOps.java:747) ~[?:1.8.0_352]
at java.util.stream.ReduceOps$ReduceTask.doLeaf(ReduceOps.java:721) ~[?:1.8.0_352]
at java.util.stream.AbstractTask.compute(AbstractTask.java:327) ~[?:1.8.0_352]
at java.util.concurrent.CountedCompleter.exec(CountedCompleter.java:731) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinTask.doInvoke(ForkJoinTask.java:401) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinTask.invoke(ForkJoinTask.java:734) ~[?:1.8.0_352]
at java.util.stream.ReduceOps$ReduceOp.evaluateParallel(ReduceOps.java:714) ~[?:1.8.0_352]
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:233) ~[?:1.8.0_352]
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566) ~[?:1.8.0_352]
at org.apache.paimon.operation.AbstractFileStoreScan.lambda$doPlan$3(AbstractFileStoreScan.java:240) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.utils.ParallellyExecuteUtils$1.lambda$advanceIfNeeded$0(ParallellyExecuteUtils.java:78) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_352]
at java.util.concurrent.CompletableFuture$AsyncSupply.exec(CompletableFuture.java:1596) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) ~[?:1.8.0_352]
2024-04-22 09:29:51,639 WARN (starrocks-mysql-nio-pool-18|41158) [StmtExecutor.execute():694] execute Exception, sql /* ApplicationName=DBeaver 23.0.2 - SQLEditor <Script-216.sql> */ SELECT
*
from quanll_ipfix_test limit 10

java.lang.RuntimeException: java.util.concurrent.ExecutionException: java.lang.IndexOutOfBoundsException: Index: 13, Size: 13
at org.apache.paimon.utils.ParallellyExecuteUtils$1.advanceIfNeeded(ParallellyExecuteUtils.java:82) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.utils.ParallellyExecuteUtils$1.hasNext(ParallellyExecuteUtils.java:57) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.manifest.ManifestEntry.mergeEntries(ManifestEntry.java:123) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.manifest.ManifestEntry.mergeEntries(ManifestEntry.java:117) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.operation.AbstractFileStoreScan.doPlan(AbstractFileStoreScan.java:245) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.operation.AbstractFileStoreScan.plan(AbstractFileStoreScan.java:192) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.table.source.snapshot.SnapshotReaderImpl.read(SnapshotReaderImpl.java:179) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.table.source.snapshot.FullStartingScanner.scan(FullStartingScanner.java:41) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.table.source.InnerTableScanImpl.plan(InnerTableScanImpl.java:62) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.table.source.InnerTableScanImpl.plan(InnerTableScanImpl.java:29) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at com.starrocks.connector.paimon.PaimonMetadata.getRemoteFileInfos(PaimonMetadata.java:195) ~[starrocks-fe.jar:?]
at com.starrocks.server.MetadataMgr.getRemoteFileInfos(MetadataMgr.java:329) ~[starrocks-fe.jar:?]
at com.starrocks.connector.paimon.PaimonMetadata.getTableStatistics(PaimonMetadata.java:222) ~[starrocks-fe.jar:?]
at com.starrocks.server.MetadataMgr.lambda$getTableStatistics$5(MetadataMgr.java:316) ~[starrocks-fe.jar:?]
at java.util.Optional.map(Optional.java:215) ~[?:1.8.0_352]
at com.starrocks.server.MetadataMgr.getTableStatistics(MetadataMgr.java:315) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.computePaimonScanNode(StatisticsCalculator.java:368) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.visitLogicalPaimonScan(StatisticsCalculator.java:356) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.visitLogicalPaimonScan(StatisticsCalculator.java:159) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.logical.LogicalPaimonScanOperator.accept(LogicalPaimonScanOperator.java:47) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.estimatorStats(StatisticsCalculator.java:175) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.task.DeriveStatsTask.execute(DeriveStatsTask.java:57) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.task.SeriallyTaskScheduler.executeTasks(SeriallyTaskScheduler.java:69) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.memoOptimize(Optimizer.java:595) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.optimizeByCost(Optimizer.java:201) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.optimize(Optimizer.java:134) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.createQueryPlan(StatementPlanner.java:142) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.planQuery(StatementPlanner.java:117) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.plan(StatementPlanner.java:92) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.plan(StatementPlanner.java:57) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.execute(StmtExecutor.java:462) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:366) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.dispatch(ConnectProcessor.java:480) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.processOnce(ConnectProcessor.java:756) ~[starrocks-fe.jar:?]
at com.starrocks.mysql.nio.ReadListener.lambda$handleEvent$0(ReadListener.java:69) ~[starrocks-fe.jar:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_352]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_352]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_352]
Caused by: java.util.concurrent.ExecutionException: java.lang.IndexOutOfBoundsException: Index: 13, Size: 13
at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_352]
at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) ~[?:1.8.0_352]
at org.apache.paimon.utils.ParallellyExecuteUtils$1.advanceIfNeeded(ParallellyExecuteUtils.java:80) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
… 37 more
Caused by: java.lang.IndexOutOfBoundsException: Index: 13, Size: 13
at java.util.ArrayList.rangeCheck(ArrayList.java:659) ~[?:1.8.0_352]
at java.util.ArrayList.get(ArrayList.java:435) ~[?:1.8.0_352]
at org.apache.paimon.format.avro.FieldReaderFactory$RowReader.(FieldReaderFactory.java:455) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory$RowReader.(FieldReaderFactory.java:447) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory.visitRecord(FieldReaderFactory.java:147) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory.visitRecord(FieldReaderFactory.java:44) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroSchemaVisitor.visit(AvroSchemaVisitor.java:41) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory.visitUnion(FieldReaderFactory.java:70) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory.visitUnion(FieldReaderFactory.java:44) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroSchemaVisitor.visit(AvroSchemaVisitor.java:44) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory$RowReader.(FieldReaderFactory.java:456) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.FieldReaderFactory.createRowReader(FieldReaderFactory.java:436) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroRowDatumReader.setSchema(AvroRowDatumReader.java:54) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.shade.org.apache.avro.file.DataFileStream.initialize(DataFileStream.java:145) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.shade.org.apache.avro.file.DataFileReader.(DataFileReader.java:143) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.shade.org.apache.avro.file.DataFileReader.(DataFileReader.java:134) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.shade.org.apache.avro.file.DataFileReader.openReader(DataFileReader.java:74) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroBulkFormat$AvroReader.createReaderFromPath(AvroBulkFormat.java:81) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroBulkFormat$AvroReader.(AvroBulkFormat.java:68) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroBulkFormat$AvroReader.(AvroBulkFormat.java:58) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroBulkFormat.createReader(AvroBulkFormat.java:55) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.format.avro.AvroBulkFormat.createReader(AvroBulkFormat.java:41) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.utils.FileUtils.createFormatReader(FileUtils.java:128) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.utils.ObjectsFile.read(ObjectsFile.java:97) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.operation.AbstractFileStoreScan.readManifestFileMeta(AbstractFileStoreScan.java:341) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.operation.AbstractFileStoreScan.lambda$null$2(AbstractFileStoreScan.java:238) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:269) ~[?:1.8.0_352]
at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175) ~[?:1.8.0_352]
at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384) ~[?:1.8.0_352]
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) ~[?:1.8.0_352]
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) ~[?:1.8.0_352]
at java.util.stream.ReduceOps$ReduceTask.doLeaf(ReduceOps.java:747) ~[?:1.8.0_352]
at java.util.stream.ReduceOps$ReduceTask.doLeaf(ReduceOps.java:721) ~[?:1.8.0_352]
at java.util.stream.AbstractTask.compute(AbstractTask.java:327) ~[?:1.8.0_352]
at java.util.concurrent.CountedCompleter.exec(CountedCompleter.java:731) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinTask.doInvoke(ForkJoinTask.java:401) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinTask.invoke(ForkJoinTask.java:734) ~[?:1.8.0_352]
at java.util.stream.ReduceOps$ReduceOp.evaluateParallel(ReduceOps.java:714) ~[?:1.8.0_352]
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:233) ~[?:1.8.0_352]
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566) ~[?:1.8.0_352]
at org.apache.paimon.operation.AbstractFileStoreScan.lambda$doPlan$3(AbstractFileStoreScan.java:240) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at org.apache.paimon.utils.ParallellyExecuteUtils$1.lambda$advanceIfNeeded$0(ParallellyExecuteUtils.java:78) ~[paimon-bundle-0.5.0-incubating.jar:0.5.0-incubating]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_352]
at java.util.concurrent.CompletableFuture$AsyncSupply.exec(CompletableFuture.java:1596) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) ~[?:1.8.0_352]
at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) ~[?:1.8.0_352]

#4

收到了，我们正在排查，请稍等

#5

paimon版本的问题，StarRocks升级到3.2可以解决

#6

麻烦问下，有修复的PR么？我们这边用的StarRocks3.1，不太方便大版本升级，想把修复的PR合过来

京ICP备2022026421号-1