Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Formatting fixes #20330

Merged
merged 2 commits into from
Jan 11, 2024

Remove redundant lambda braces

3b77bc4
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
Merged

Formatting fixes #20330

Remove redundant lambda braces
3b77bc4
Select commit
Loading
Failed to load commit list.
GitHub Actions / Test Report failed Jan 10, 2024 in 0s

4791 tests: 4790 passed, 1 failed. Elapsed 5h 14m 34s.

Annotations

Check failure on line 103 in io/trino/tests/product/hive/TestHiveTransactionalTable

See this annotation in the file changed.

@github-actions github-actions / Test Report

TestHiveTransactionalTable > testReadFullAcid [groups: hive_transactional]

java.sql.SQLException: Query failed (#20240110_183725_00547_6imfv): Found file in sub-directory of ACID directory: hdfs://hadoop-master:9000/user/hive/warehouse/test_read_full_acid_false_none_97v4p37441/delete_delta_0000002_0000005/delete_delta_0000002_0000005/bucket_00000
Raw output
io.trino.tempto.query.QueryExecutionException: java.sql.SQLException: Query failed (#20240110_183725_00547_6imfv): Found file in sub-directory of ACID directory: hdfs://hadoop-master:9000/user/hive/warehouse/test_read_full_acid_false_none_97v4p37441/delete_delta_0000002_0000005/delete_delta_0000002_0000005/bucket_00000
	at io.trino.tempto.query.JdbcQueryExecutor.execute(JdbcQueryExecutor.java:119)
	at io.trino.tempto.query.JdbcQueryExecutor.executeQuery(JdbcQueryExecutor.java:84)
	at io.trino.tests.product.utils.QueryExecutors$1.lambda$executeQuery$0(QueryExecutors.java:54)
	at dev.failsafe.Functions.lambda$toCtxSupplier$11(Functions.java:243)
	at dev.failsafe.Functions.lambda$get$0(Functions.java:46)
	at dev.failsafe.internal.RetryPolicyExecutor.lambda$apply$0(RetryPolicyExecutor.java:74)
	at dev.failsafe.SyncExecutionImpl.executeSync(SyncExecutionImpl.java:187)
	at dev.failsafe.FailsafeExecutor.call(FailsafeExecutor.java:376)
	at dev.failsafe.FailsafeExecutor.get(FailsafeExecutor.java:112)
	at io.trino.tests.product.utils.QueryExecutors$1.executeQuery(QueryExecutors.java:54)
	at io.trino.tests.product.hive.TestHiveTransactionalTable.doTestReadFullAcid(TestHiveTransactionalTable.java:177)
	at io.trino.tests.product.hive.TestHiveTransactionalTable.testReadFullAcid(TestHiveTransactionalTable.java:103)
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:104)
	at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:54)
	at org.testng.internal.InvokeMethodRunnable.run(InvokeMethodRunnable.java:44)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.sql.SQLException: Query failed (#20240110_183725_00547_6imfv): Found file in sub-directory of ACID directory: hdfs://hadoop-master:9000/user/hive/warehouse/test_read_full_acid_false_none_97v4p37441/delete_delta_0000002_0000005/delete_delta_0000002_0000005/bucket_00000
	at io.trino.jdbc.AbstractTrinoResultSet.resultsException(AbstractTrinoResultSet.java:1937)
	at io.trino.jdbc.TrinoResultSet$ResultsPageIterator.computeNext(TrinoResultSet.java:294)
	at io.trino.jdbc.TrinoResultSet$ResultsPageIterator.computeNext(TrinoResultSet.java:254)
	at io.trino.jdbc.$internal.guava.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
	at io.trino.jdbc.$internal.guava.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
	at java.base/java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1949)
	at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:292)
	at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206)
	at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:161)
	at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:298)
	at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681)
	at io.trino.jdbc.TrinoResultSet$AsyncIterator.lambda$new$1(TrinoResultSet.java:179)
	... 5 more
	Suppressed: java.lang.Exception: Query: SELECT col, fcol FROM test_read_full_acid_false_NONE_97v4p37441 ORDER BY col
		at io.trino.tempto.query.JdbcQueryExecutor.executeQueryNoParams(JdbcQueryExecutor.java:136)
		at io.trino.tempto.query.JdbcQueryExecutor.execute(JdbcQueryExecutor.java:112)
		at io.trino.tempto.query.JdbcQueryExecutor.executeQuery(JdbcQueryExecutor.java:84)
		at io.trino.tests.product.utils.QueryExecutors$1.lambda$executeQuery$0(QueryExecutors.java:54)
		at dev.failsafe.Functions.lambda$toCtxSupplier$11(Functions.java:243)
		at dev.failsafe.Functions.lambda$get$0(Functions.java:46)
		at dev.failsafe.internal.RetryPolicyExecutor.lambda$apply$0(RetryPolicyExecutor.java:74)
		at dev.failsafe.SyncExecutionImpl.executeSync(SyncExecutionImpl.java:187)
		at dev.failsafe.FailsafeExecutor.call(FailsafeExecutor.java:376)
		at dev.failsafe.FailsafeExecutor.get(FailsafeExecutor.java:112)
		at io.trino.tests.product.utils.QueryExecutors$1.executeQuery(QueryExecutors.java:54)
		at io.trino.tests.product.hive.TestHiveTransactionalTable.doTestReadFullAcid(TestHiveTransactionalTable.java:177)
		at io.trino.tests.product.hive.TestHiveTransactionalTable.testReadFullAcid(TestHiveTransactionalTable.java:103)
		at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
		at java.base/java.lang.reflect.Method.invoke(Method.java:580)
		at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:104)
		at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:54)
		at org.testng.internal.InvokeMethodRunnable.run(InvokeMethodRunnable.java:44)
		... 5 more
Caused by: io.trino.spi.TrinoException: Found file in sub-directory of ACID directory: hdfs://hadoop-master:9000/user/hive/warehouse/test_read_full_acid_false_none_97v4p37441/delete_delta_0000002_0000005/delete_delta_0000002_0000005/bucket_00000
	at io.trino.plugin.hive.util.AcidTables.getAcidState(AcidTables.java:136)
	at io.trino.plugin.hive.BackgroundHiveSplitLoader.getTransactionalSplits(BackgroundHiveSplitLoader.java:539)
	at io.trino.plugin.hive.BackgroundHiveSplitLoader.loadPartition(BackgroundHiveSplitLoader.java:481)
	at io.trino.plugin.hive.BackgroundHiveSplitLoader.loadSplits(BackgroundHiveSplitLoader.java:366)
	at io.trino.plugin.hive.BackgroundHiveSplitLoader$HiveSplitLoaderTask.process(BackgroundHiveSplitLoader.java:280)
	at io.trino.plugin.hive.util.ResumableTasks$1.run(ResumableTasks.java:38)
	at io.trino.$gen.Trino_435_192_g094f555____20240110_182449_2.run(Unknown Source)
	at io.airlift.concurrent.BoundedExecutor.drainQueue(BoundedExecutor.java:79)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)