Skip to content
milestone

Provide default implementations in ConnectorSplit #5504

Sign in to view logs

Provide default implementations in ConnectorSplit

Provide default implementations in ConnectorSplit #5504

GitHub Actions / Test Report failed Nov 7, 2023 in 0s

5032 tests: 5026 passed, 6 failed. Elapsed 8h 6m 33s.

Annotations

Check failure on line 247 in io/trino/tests/product/deltalake/TestDeltaLakePartitioningCompatibility

See this annotation in the file changed.

@github-actions github-actions / Test Report

TestDeltaLakePartitioningCompatibility > testSparkCanReadFromTableUpdatedByTrino [groups: profile_specific_tests, delta-lake-oss] 

java.sql.SQLException: org.apache.hive.org.apache.thrift.transport.TTransportException: java.net.SocketException: Broken pipe
Raw output 
io.trino.tempto.query.QueryExecutionException: java.sql.SQLException: org.apache.hive.org.apache.thrift.transport.TTransportException: java.net.SocketException: Broken pipe
	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$3.lambda$executeQuery$0(QueryExecutors.java:136)
	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$3.executeQuery(QueryExecutors.java:136)
	at io.trino.tests.product.deltalake.util.DeltaLakeTestUtils.lambda$dropDeltaTableWithRetry$6(DeltaLakeTestUtils.java:144)
	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.deltalake.util.DeltaLakeTestUtils.dropDeltaTableWithRetry(DeltaLakeTestUtils.java:144)
	at io.trino.tests.product.deltalake.TestDeltaLakePartitioningCompatibility.testSparkCanReadFromTableUpdatedByTrinoWithCpIntervalSet(TestDeltaLakePartitioningCompatibility.java:291)
	at io.trino.tests.product.deltalake.TestDeltaLakePartitioningCompatibility.testSparkCanReadFromTableUpdatedByTrino(TestDeltaLakePartitioningCompatibility.java:247)
	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.Invoker.invokeMethod(Invoker.java:645)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112)
	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: org.apache.hive.org.apache.thrift.transport.TTransportException: java.net.SocketException: Broken pipe
	at org.apache.hive.jdbc.HiveStatement.runAsyncOnServer(HiveStatement.java:334)
	at org.apache.hive.jdbc.HiveStatement.execute(HiveStatement.java:265)
	at io.trino.tempto.query.JdbcQueryExecutor.executeQueryNoParams(JdbcQueryExecutor.java:128)
	at io.trino.tempto.query.JdbcQueryExecutor.execute(JdbcQueryExecutor.java:112)
	... 30 more
	Suppressed: java.lang.Exception: Query: DROP TABLE IF EXISTS default.test_dl_create_table_partition_by_special_char_with_20_partitions_996lo2fdnx
		at io.trino.tempto.query.JdbcQueryExecutor.executeQueryNoParams(JdbcQueryExecutor.java:136)
		... 31 more
Caused by: org.apache.hive.org.apache.thrift.transport.TTransportException: java.net.SocketException: Broken pipe
	at org.apache.hive.org.apache.thrift.transport.TIOStreamTransport.flush(TIOStreamTransport.java:161)
	at org.apache.hive.org.apache.thrift.transport.TSaslTransport.flush(TSaslTransport.java:501)
	at org.apache.hive.org.apache.thrift.transport.TSaslClientTransport.flush(TSaslClientTransport.java:37)
	at org.apache.hive.org.apache.thrift.TServiceClient.sendBase(TServiceClient.java:73)
	at org.apache.hive.org.apache.thrift.TServiceClient.sendBase(TServiceClient.java:62)
	at org.apache.hive.service.rpc.thrift.TCLIService$Client.send_ExecuteStatement(TCLIService.java:239)
	at org.apache.hive.service.rpc.thrift.TCLIService$Client.ExecuteStatement(TCLIService.java:231)
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at org.apache.hive.jdbc.HiveConnection$SynchronizedHandler.invoke(HiveConnection.java:1585)
	at jdk.proxy3/jdk.proxy3.$Proxy59.ExecuteStatement(Unknown Source)
	at org.apache.hive.jdbc.HiveStatement.runAsyncOnServer(HiveStatement.java:323)
	... 33 more
Caused by: java.net.SocketException: Broken pipe
	at java.base/sun.nio.ch.SocketDispatcher.write0(Native Method)
	at java.base/sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:62)
	at java.base/sun.nio.ch.NioSocketImpl.tryWrite(NioSocketImpl.java:394)
	at java.base/sun.nio.ch.NioSocketImpl.implWrite(NioSocketImpl.java:410)
	at java.base/sun.nio.ch.NioSocketImpl.write(NioSocketImpl.java:440)
	at java.base/sun.nio.ch.NioSocketImpl$2.write(NioSocketImpl.java:819)
	at java.base/java.net.Socket$SocketOutputStream.write(Socket.java:1195)
	at java.base/java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:125)
	at java.base/java.io.BufferedOutputStream.implFlush(BufferedOutputStream.java:252)
	at java.base/java.io.BufferedOutputStream.flush(BufferedOutputStream.java:240)
	at org.apache.hive.org.apache.thrift.transport.TIOStreamTransport.flush(TIOStreamTransport.java:159)
	... 44 more

Check failure on line 139 in io/trino/tests/product/deltalake/TestDeltaLakePartitioningCompatibility

See this annotation in the file changed.

@github-actions github-actions / Test Report

TestDeltaLakePartitioningCompatibility > testSparkCanReadTableCreatedByTrinoWithSpecialCharactersInPartitioningColumn [groups: profile_specific_tests, delta-lake-oss] 

java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
Raw output 
java.lang.RuntimeException: java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
	at io.trino.tempto.query.JdbcQueryExecutor.openConnection(JdbcQueryExecutor.java:63)
	at io.trino.tempto.query.JdbcQueryExecutor.execute(JdbcQueryExecutor.java:103)
	at io.trino.tempto.query.JdbcQueryExecutor.executeQuery(JdbcQueryExecutor.java:84)
	at io.trino.tests.product.utils.QueryExecutors$3.lambda$executeQuery$0(QueryExecutors.java:136)
	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$3.executeQuery(QueryExecutors.java:136)
	at io.trino.tests.product.deltalake.util.DeltaLakeTestUtils.lambda$dropDeltaTableWithRetry$6(DeltaLakeTestUtils.java:144)
	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.deltalake.util.DeltaLakeTestUtils.dropDeltaTableWithRetry(DeltaLakeTestUtils.java:144)
	at io.trino.tests.product.deltalake.TestDeltaLakePartitioningCompatibility.testSparkCanReadTableCreatedByTrinoWithSpecialCharactersInPartitioningColumnWithCpIntervalSet(TestDeltaLakePartitioningCompatibility.java:184)
	at io.trino.tests.product.deltalake.TestDeltaLakePartitioningCompatibility.testSparkCanReadTableCreatedByTrinoWithSpecialCharactersInPartitioningColumn(TestDeltaLakePartitioningCompatibility.java:139)
	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.Invoker.invokeMethod(Invoker.java:645)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112)
	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: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
	at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:256)
	at org.apache.hive.jdbc.HiveDriver.connect(HiveDriver.java:107)
	at io.trino.tempto.internal.query.NonPoolingJdbcDataSource.getConnection(NonPoolingJdbcDataSource.java:51)
	at io.trino.tempto.query.JdbcConnectionsPool.createConnection(JdbcConnectionsPool.java:40)
	at io.trino.tempto.query.JdbcConnectionsPool.connectionFor(JdbcConnectionsPool.java:34)
	at io.trino.tempto.query.JdbcQueryExecutor.openConnection(JdbcQueryExecutor.java:60)
	... 31 more
Caused by: org.apache.hive.org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
	at org.apache.hive.org.apache.thrift.transport.TSocket.open(TSocket.java:226)
	at org.apache.hive.org.apache.thrift.transport.TSaslTransport.open(TSaslTransport.java:266)
	at org.apache.hive.org.apache.thrift.transport.TSaslClientTransport.open(TSaslClientTransport.java:37)
	at org.apache.hive.jdbc.HiveConnection.openTransport(HiveConnection.java:343)
	at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:228)
	... 36 more
Caused by: java.net.ConnectException: Connection refused
	at java.base/sun.nio.ch.Net.connect0(Native Method)
	at java.base/sun.nio.ch.Net.connect(Net.java:589)
	at java.base/sun.nio.ch.Net.connect(Net.java:578)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:583)
	at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
	at java.base/java.net.Socket.connect(Socket.java:751)
	at org.apache.hive.org.apache.thrift.transport.TSocket.open(TSocket.java:221)
	... 40 more

Check failure on line 86 in io/trino/tests/product/deltalake/TestDeltaLakePartitioningCompatibility

See this annotation in the file changed.

@github-actions github-actions / Test Report

TestDeltaLakePartitioningCompatibility > testTrinoCanReadFromCtasTableCreatedBySparkWithSpecialCharactersInPartitioningColumn [groups: profile_specific_tests, delta-lake-oss] 

java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
Raw output 
java.lang.RuntimeException: java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
	at io.trino.tempto.query.JdbcQueryExecutor.openConnection(JdbcQueryExecutor.java:63)
	at io.trino.tempto.query.JdbcQueryExecutor.execute(JdbcQueryExecutor.java:103)
	at io.trino.tempto.query.JdbcQueryExecutor.executeQuery(JdbcQueryExecutor.java:84)
	at io.trino.tests.product.utils.QueryExecutors$3.lambda$executeQuery$0(QueryExecutors.java:136)
	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$3.executeQuery(QueryExecutors.java:136)
	at io.trino.tests.product.deltalake.TestDeltaLakePartitioningCompatibility.testTrinoCanReadFromCtasTableCreatedBySparkWithSpecialCharactersInPartitioningColumnWithCpIntervalSet(TestDeltaLakePartitioningCompatibility.java:107)
	at io.trino.tests.product.deltalake.TestDeltaLakePartitioningCompatibility.testTrinoCanReadFromCtasTableCreatedBySparkWithSpecialCharactersInPartitioningColumn(TestDeltaLakePartitioningCompatibility.java:86)
	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.Invoker.invokeMethod(Invoker.java:645)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112)
	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: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
	at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:256)
	at org.apache.hive.jdbc.HiveDriver.connect(HiveDriver.java:107)
	at io.trino.tempto.internal.query.NonPoolingJdbcDataSource.getConnection(NonPoolingJdbcDataSource.java:51)
	at io.trino.tempto.query.JdbcConnectionsPool.createConnection(JdbcConnectionsPool.java:40)
	at io.trino.tempto.query.JdbcConnectionsPool.connectionFor(JdbcConnectionsPool.java:34)
	at io.trino.tempto.query.JdbcQueryExecutor.openConnection(JdbcQueryExecutor.java:60)
	... 23 more
Caused by: org.apache.hive.org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
	at org.apache.hive.org.apache.thrift.transport.TSocket.open(TSocket.java:226)
	at org.apache.hive.org.apache.thrift.transport.TSaslTransport.open(TSaslTransport.java:266)
	at org.apache.hive.org.apache.thrift.transport.TSaslClientTransport.open(TSaslClientTransport.java:37)
	at org.apache.hive.jdbc.HiveConnection.openTransport(HiveConnection.java:343)
	at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:228)
	... 28 more
Caused by: java.net.ConnectException: Connection refused
	at java.base/sun.nio.ch.Net.connect0(Native Method)
	at java.base/sun.nio.ch.Net.connect(Net.java:589)
	at java.base/sun.nio.ch.Net.connect(Net.java:578)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:583)
	at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
	at java.base/java.net.Socket.connect(Socket.java:751)
	at org.apache.hive.org.apache.thrift.transport.TSocket.open(TSocket.java:221)
	... 32 more

Check failure on line 358 in io/trino/tests/product/deltalake/TestDeltaLakePartitioningCompatibility

See this annotation in the file changed.

@github-actions github-actions / Test Report

TestDeltaLakePartitioningCompatibility > testTrinoCanReadFromTablePartitionChangedBySpark [groups: profile_specific_tests, delta-lake-oss] 

java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
Raw output 
java.lang.RuntimeException: java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
	at io.trino.tempto.query.JdbcQueryExecutor.openConnection(JdbcQueryExecutor.java:63)
	at io.trino.tempto.query.JdbcQueryExecutor.execute(JdbcQueryExecutor.java:103)
	at io.trino.tempto.query.JdbcQueryExecutor.executeQuery(JdbcQueryExecutor.java:84)
	at io.trino.tests.product.utils.QueryExecutors$3.lambda$executeQuery$0(QueryExecutors.java:136)
	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$3.executeQuery(QueryExecutors.java:136)
	at io.trino.tests.product.deltalake.TestDeltaLakePartitioningCompatibility.testTrinoCanReadFromTablePartitionChangedBySpark(TestDeltaLakePartitioningCompatibility.java:358)
	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.Invoker.invokeMethod(Invoker.java:645)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112)
	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: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
	at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:256)
	at org.apache.hive.jdbc.HiveDriver.connect(HiveDriver.java:107)
	at io.trino.tempto.internal.query.NonPoolingJdbcDataSource.getConnection(NonPoolingJdbcDataSource.java:51)
	at io.trino.tempto.query.JdbcConnectionsPool.createConnection(JdbcConnectionsPool.java:40)
	at io.trino.tempto.query.JdbcConnectionsPool.connectionFor(JdbcConnectionsPool.java:34)
	at io.trino.tempto.query.JdbcQueryExecutor.openConnection(JdbcQueryExecutor.java:60)
	... 22 more
Caused by: org.apache.hive.org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
	at org.apache.hive.org.apache.thrift.transport.TSocket.open(TSocket.java:226)
	at org.apache.hive.org.apache.thrift.transport.TSaslTransport.open(TSaslTransport.java:266)
	at org.apache.hive.org.apache.thrift.transport.TSaslClientTransport.open(TSaslClientTransport.java:37)
	at org.apache.hive.jdbc.HiveConnection.openTransport(HiveConnection.java:343)
	at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:228)
	... 27 more
Caused by: java.net.ConnectException: Connection refused
	at java.base/sun.nio.ch.Net.connect0(Native Method)
	at java.base/sun.nio.ch.Net.connect(Net.java:589)
	at java.base/sun.nio.ch.Net.connect(Net.java:578)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:583)
	at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
	at java.base/java.net.Socket.connect(Socket.java:751)
	at org.apache.hive.org.apache.thrift.transport.TSocket.open(TSocket.java:221)
	... 31 more

Check failure on line 298 in io/trino/tests/product/deltalake/TestDeltaLakePartitioningCompatibility

See this annotation in the file changed.

@github-actions github-actions / Test Report

TestDeltaLakePartitioningCompatibility > testTrinoCanReadFromTableUpdatedBySpark [groups: profile_specific_tests, delta-lake-oss] 

java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
Raw output 
java.lang.RuntimeException: java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
	at io.trino.tempto.query.JdbcQueryExecutor.openConnection(JdbcQueryExecutor.java:63)
	at io.trino.tempto.query.JdbcQueryExecutor.execute(JdbcQueryExecutor.java:103)
	at io.trino.tempto.query.JdbcQueryExecutor.executeQuery(JdbcQueryExecutor.java:84)
	at io.trino.tests.product.utils.QueryExecutors$3.lambda$executeQuery$0(QueryExecutors.java:136)
	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$3.executeQuery(QueryExecutors.java:136)
	at io.trino.tests.product.deltalake.TestDeltaLakePartitioningCompatibility.testTrinoCanReadFromTableUpdatedBySparkWithCpIntervalSet(TestDeltaLakePartitioningCompatibility.java:319)
	at io.trino.tests.product.deltalake.TestDeltaLakePartitioningCompatibility.testTrinoCanReadFromTableUpdatedBySpark(TestDeltaLakePartitioningCompatibility.java:298)
	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.Invoker.invokeMethod(Invoker.java:645)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112)
	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: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
	at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:256)
	at org.apache.hive.jdbc.HiveDriver.connect(HiveDriver.java:107)
	at io.trino.tempto.internal.query.NonPoolingJdbcDataSource.getConnection(NonPoolingJdbcDataSource.java:51)
	at io.trino.tempto.query.JdbcConnectionsPool.createConnection(JdbcConnectionsPool.java:40)
	at io.trino.tempto.query.JdbcConnectionsPool.connectionFor(JdbcConnectionsPool.java:34)
	at io.trino.tempto.query.JdbcQueryExecutor.openConnection(JdbcQueryExecutor.java:60)
	... 23 more
Caused by: org.apache.hive.org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
	at org.apache.hive.org.apache.thrift.transport.TSocket.open(TSocket.java:226)
	at org.apache.hive.org.apache.thrift.transport.TSaslTransport.open(TSaslTransport.java:266)
	at org.apache.hive.org.apache.thrift.transport.TSaslClientTransport.open(TSaslClientTransport.java:37)
	at org.apache.hive.jdbc.HiveConnection.openTransport(HiveConnection.java:343)
	at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:228)
	... 28 more
Caused by: java.net.ConnectException: Connection refused
	at java.base/sun.nio.ch.Net.connect0(Native Method)
	at java.base/sun.nio.ch.Net.connect(Net.java:589)
	at java.base/sun.nio.ch.Net.connect(Net.java:578)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:583)
	at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
	at java.base/java.net.Socket.connect(Socket.java:751)
	at org.apache.hive.org.apache.thrift.transport.TSocket.open(TSocket.java:221)
	... 32 more

Check failure on line 191 in io/trino/tests/product/deltalake/TestDeltaLakePartitioningCompatibility

See this annotation in the file changed.

@github-actions github-actions / Test Report

TestDeltaLakePartitioningCompatibility > testTrinoCanReadTableCreatedBySaprkWithSpecialCharactersInPartitioningColumn [groups: profile_specific_tests, delta-lake-oss] 

java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
Raw output 
java.lang.RuntimeException: java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
	at io.trino.tempto.query.JdbcQueryExecutor.openConnection(JdbcQueryExecutor.java:63)
	at io.trino.tempto.query.JdbcQueryExecutor.execute(JdbcQueryExecutor.java:103)
	at io.trino.tempto.query.JdbcQueryExecutor.executeQuery(JdbcQueryExecutor.java:84)
	at io.trino.tests.product.utils.QueryExecutors$3.lambda$executeQuery$0(QueryExecutors.java:136)
	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$3.executeQuery(QueryExecutors.java:136)
	at io.trino.tests.product.deltalake.TestDeltaLakePartitioningCompatibility.testTrinoCanReadTableCreatedBySparkWithSpecialCharactersInPartitioningColumnWithCpIntervalSet(TestDeltaLakePartitioningCompatibility.java:212)
	at io.trino.tests.product.deltalake.TestDeltaLakePartitioningCompatibility.testTrinoCanReadTableCreatedBySaprkWithSpecialCharactersInPartitioningColumn(TestDeltaLakePartitioningCompatibility.java:191)
	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.Invoker.invokeMethod(Invoker.java:645)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112)
	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: Could not open client transport with JDBC Uri: jdbc:hive2://spark:10213: java.net.ConnectException: Connection refused
	at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:256)
	at org.apache.hive.jdbc.HiveDriver.connect(HiveDriver.java:107)
	at io.trino.tempto.internal.query.NonPoolingJdbcDataSource.getConnection(NonPoolingJdbcDataSource.java:51)
	at io.trino.tempto.query.JdbcConnectionsPool.createConnection(JdbcConnectionsPool.java:40)
	at io.trino.tempto.query.JdbcConnectionsPool.connectionFor(JdbcConnectionsPool.java:34)
	at io.trino.tempto.query.JdbcQueryExecutor.openConnection(JdbcQueryExecutor.java:60)
	... 23 more
Caused by: org.apache.hive.org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
	at org.apache.hive.org.apache.thrift.transport.TSocket.open(TSocket.java:226)
	at org.apache.hive.org.apache.thrift.transport.TSaslTransport.open(TSaslTransport.java:266)
	at org.apache.hive.org.apache.thrift.transport.TSaslClientTransport.open(TSaslClientTransport.java:37)
	at org.apache.hive.jdbc.HiveConnection.openTransport(HiveConnection.java:343)
	at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:228)
	... 28 more
Caused by: java.net.ConnectException: Connection refused
	at java.base/sun.nio.ch.Net.connect0(Native Method)
	at java.base/sun.nio.ch.Net.connect(Net.java:589)
	at java.base/sun.nio.ch.Net.connect(Net.java:578)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:583)
	at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
	at java.base/java.net.Socket.connect(Socket.java:751)
	at org.apache.hive.org.apache.thrift.transport.TSocket.open(TSocket.java:221)
	... 32 more
View more details on GitHub Actions