Skip to content

feat: DH-18399: Add ParquetColumnResolver #2620

feat: DH-18399: Add ParquetColumnResolver

feat: DH-18399: Add ParquetColumnResolver #2620

GitHub Actions / check-ci test report failed Jan 16, 2025 in 0s

10250 tests run, 42 skipped, 1 failed.

Annotations

Check failure on line 1095 in io/deephaven/parquet/table/TestParquetTools

See this annotation in the file changed.

@github-actions github-actions / check-ci test report

TestParquetTools.parquetWithNonUniqueFieldIds

java.lang.IllegalArgumentException: Parquet columns can't be unambigously mapped. Bar -> 31337 has multiple paths [Foo], [Bar]
Raw output
java.lang.IllegalArgumentException: Parquet columns can't be unambigously mapped. Bar -> 31337 has multiple paths [Foo], [Bar]
	at io.deephaven.parquet.table.location.ParquetFieldIdColumnResolverFactory$FieldIdMappingVisitor.accept(ParquetFieldIdColumnResolverFactory.java:143)
	at io.deephaven.parquet.table.location.ParquetUtil.walk(ParquetUtil.java:133)
	at io.deephaven.parquet.table.location.ParquetUtil.walk(ParquetUtil.java:142)
	at io.deephaven.parquet.table.location.ParquetUtil.walk(ParquetUtil.java:60)
	at io.deephaven.parquet.table.location.ParquetFieldIdColumnResolverFactory.of(ParquetFieldIdColumnResolverFactory.java:98)
	at io.deephaven.parquet.table.location.ParquetFieldIdColumnResolverFactory.of(ParquetFieldIdColumnResolverFactory.java:118)
	at io.deephaven.parquet.table.location.ParquetFieldIdColumnResolverFactory.of(ParquetFieldIdColumnResolverFactory.java:67)
	at io.deephaven.parquet.table.location.ParquetTableLocation.lambda$new$0(ParquetTableLocation.java:94)
	at java.base/java.util.Optional.map(Optional.java:260)
	at io.deephaven.parquet.table.location.ParquetTableLocation.<init>(ParquetTableLocation.java:94)
	at io.deephaven.parquet.table.location.ParquetTableLocationFactory.makeLocation(ParquetTableLocationFactory.java:38)
	at io.deephaven.parquet.table.location.ParquetTableLocationFactory.makeLocation(ParquetTableLocationFactory.java:23)
	at io.deephaven.engine.table.impl.locations.impl.PollingTableLocationProvider.makeTableLocation(PollingTableLocationProvider.java:59)
	at io.deephaven.engine.table.impl.locations.impl.AbstractTableLocationProvider$TrackedKeySupplier.getTableLocation(AbstractTableLocationProvider.java:112)
	at io.deephaven.engine.table.impl.locations.impl.AbstractTableLocationProvider.getTableLocationIfPresent(AbstractTableLocationProvider.java:537)
	at io.deephaven.engine.table.impl.locations.TableLocationProvider.getTableLocation(TableLocationProvider.java:186)
	at io.deephaven.engine.table.impl.SourceTable.lambda$maybeAddLocations$2(SourceTable.java:188)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1708)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.ForEachOps$ForEachTask.compute(ForEachOps.java:291)
	at java.base/java.util.concurrent.CountedCompleter.exec(CountedCompleter.java:754)
	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
	at java.base/java.util.concurrent.ForkJoinTask.invoke(ForkJoinTask.java:667)
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateParallel(ForEachOps.java:160)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateParallel(ForEachOps.java:174)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:233)
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
	at java.base/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:765)
	at io.deephaven.engine.table.impl.SourceTable.maybeAddLocations(SourceTable.java:188)
	at io.deephaven.engine.table.impl.SourceTable.lambda$initializeAvailableLocations$1(SourceTable.java:171)
	at io.deephaven.engine.table.impl.perf.QueryPerformanceRecorder.withNugget(QueryPerformanceRecorder.java:286)
	at io.deephaven.engine.table.impl.SourceTable.initializeAvailableLocations(SourceTable.java:148)
	at io.deephaven.engine.table.impl.SourceTable.initialize(SourceTable.java:121)
	at io.deephaven.engine.table.impl.SourceTable.doCoalesce(SourceTable.java:297)
	at io.deephaven.engine.table.impl.SourceTable.doCoalesce(SourceTable.java:35)
	at io.deephaven.engine.table.impl.UncoalescedTable.coalesce(UncoalescedTable.java:78)
	at io.deephaven.engine.table.impl.UncoalescedTable.select(UncoalescedTable.java:236)
	at io.deephaven.engine.table.impl.UncoalescedTable.select(UncoalescedTable.java:43)
	at io.deephaven.api.TableOperationsDefaults.select(TableOperationsDefaults.java:109)
	at io.deephaven.parquet.table.TestParquetTools.parquetWithNonUniqueFieldIds(TestParquetTools.java:1095)
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at io.deephaven.engine.testutil.junit4.EngineCleanup$1.evaluate(EngineCleanup.java:34)
	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
	at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
	at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
	at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:112)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:40)
	at org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:54)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:53)
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
	at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:92)
	at jdk.proxy1/jdk.proxy1.$Proxy4.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker$2.run(TestWorker.java:183)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:132)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:103)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:63)
	at org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
	at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:121)
	at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:71)
	at worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
	at worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)