Iceberg Trino Rest Catalog with Unity Catalog No Factory for location Error With metadata in Local File System #26189
Replies: 2 comments
-
After adding below property to iceberg.properties file I see exception of File Not Found. |
Beta Was this translation helpful? Give feedback.
-
The actual path exists: Caused by: java.nio.file.NoSuchFileException: **/tmp/tmp/**marksheet_uniform/metadata/snap-1249442174133317666-1-3d76bd5d-21ad-4512-9c62-35ddd82eceed.avro |
Beta Was this translation helpful? Give feedback.
Uh oh!
There was an error while loading. Please reload this page.
-
java.util.concurrent.CompletionException: io.trino.spi.TrinoException: Error processing metadata for table default.marksheet_uniform
at java.base/java.util.concurrent.CompletableFuture.wrapInCompletionException(CompletableFuture.java:325)
at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:361)
at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:366)
at java.base/java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:1040)
at java.base/java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:1020)
at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:556)
at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2246)
at io.airlift.concurrent.MoreFutures$2.onFailure(MoreFutures.java:495)
at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1117)
at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:30)
at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1004)
at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:767)
at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:516)
at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.afterRanInterruptiblyFailure(TrustedListenableFutureTask.java:138)
at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:89)
at com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:80)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1095)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:619)
at java.base/java.lang.Thread.run(Thread.java:1447)
Caused by: io.trino.spi.TrinoException: Error processing metadata for table default.marksheet_uniform
at io.trino.plugin.iceberg.IcebergExceptions.translateMetadataException(IcebergExceptions.java:54)
at io.trino.plugin.iceberg.IcebergSplitSource.lambda$getNextBatch$2(IcebergSplitSource.java:263)
at java.base/java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:1036)
... 15 more
Caused by: java.lang.IllegalArgumentException: No factory for location: file:/tmp/marksheet_uniform/metadata/snap-1249442174133317666-1-3d76bd5d-21ad-4512-9c62-35ddd82eceed.avro
at io.trino.filesystem.manager.FileSystemModule.lambda$createFileSystemFactory$2(FileSystemModule.java:161)
at java.base/java.util.Optional.orElseThrow(Optional.java:403)
at io.trino.filesystem.manager.FileSystemModule.lambda$createFileSystemFactory$0(FileSystemModule.java:161)
at io.trino.filesystem.switching.SwitchingFileSystem.fileSystem(SwitchingFileSystem.java:194)
at io.trino.filesystem.switching.SwitchingFileSystem.newInputFile(SwitchingFileSystem.java:60)
at io.trino.filesystem.tracing.TracingFileSystem.newInputFile(TracingFileSystem.java:51)
at io.trino.filesystem.cache.CacheFileSystem.newInputFile(CacheFileSystem.java:49)
at io.trino.plugin.iceberg.fileio.ForwardingFileIo.newInputFile(ForwardingFileIo.java:67)
at org.apache.iceberg.BaseSnapshot.cacheManifests(BaseSnapshot.java:176)
at org.apache.iceberg.BaseSnapshot.dataManifests(BaseSnapshot.java:202)
at org.apache.iceberg.DataTableScan.doPlanFiles(DataTableScan.java:68)
at org.apache.iceberg.SnapshotScan.planFiles(SnapshotScan.java:139)
at io.trino.plugin.iceberg.IcebergSplitSource.getNextBatchInternal(IcebergSplitSource.java:297)
at io.trino.plugin.iceberg.IcebergSplitSource.lambda$getNextBatch$1(IcebergSplitSource.java:258)
at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:128)
at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:74)
... 4 more
iceberg.properties file configured below:
connector.name=iceberg
iceberg.catalog.type=rest
iceberg.rest-catalog.uri=http://host.docker.internal:9080/api/2.1/unity-catalog/iceberg
iceberg.rest-catalog.warehouse=unity
iceberg.file-format=PARQUET
Running trino on docker and Unity catalog open source https://www.unitycatalog.io/ local set up
Beta Was this translation helpful? Give feedback.
All reactions