java.sql.SQLException: Query failed (#20250312_023909_00015_43ers): Unexpected response from http://172.19.0.4:8081/v1/task/20250312_023909_00015_43ers.2.0.0?summarize

java.sql.SQLException: Query failed (#20250312_023910_00016_43ers): Unexpected response from http://172.19.0.4:8081/v1/task/20250312_023910_00016_43ers.2.0.0?summarize

java.sql.SQLException: Query failed (#20250312_023911_00017_43ers): Unexpected response from http://172.19.0.4:8081/v1/task/20250312_023911_00017_43ers.2.0.0?summarize

java.sql.SQLException: Query failed (#20250312_023902_00008_43ers): Unexpected response from http://172.19.0.4:8081/v1/task/20250312_023902_00008_43ers.2.0.0?summarize

Expecting message: "Query failed (#20250312_023902_00009_43ers): Unexpected response from http://172.19.0.4:8081/v1/task/20250312_023902_00009_43ers.2.0.0?summarize" to match regex: "Query failed \(.+\): Unsupported column type 'array\(bigint\)' for column 'c_array'" but did not. Throwable that failed the check: java.sql.SQLException: Query failed (#20250312_023902_00009_43ers): Unexpected response from http://172.19.0.4:8081/v1/task/20250312_023902_00009_43ers.2.0.0?summarize at io.trino.jdbc.ResultUtils.resultsException(ResultUtils.java:33) at io.trino.jdbc.AsyncResultIterator.lambda$new$1(AsyncResultIterator.java:93) 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:1575) Suppressed: java.lang.Exception: Query: INSERT INTO kafka.product_tests.write_structural_datatype_avro VALUES (ARRAY[100, 102], map_from_entries(ARRAY[('key1', 'value1')])) 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.kafka.TestKafkaAvroWritesSmokeTest.lambda$testInsertStructuralDataType$0(TestKafkaAvroWritesSmokeTest.java:65) at io.trino.tempto.assertions.QueryAssert.assertQueryFailure(QueryAssert.java:108) at io.trino.tests.product.kafka.TestKafkaAvroWritesSmokeTest.testInsertStructuralDataType(TestKafkaAvroWritesSmokeTest.java:65) 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) ... 3 more Caused by: io.trino.spi.TrinoException: Unexpected response from http://172.19.0.4:8081/v1/task/20250312_023902_00009_43ers.2.0.0?summarize at io.trino.server.remotetask.SimpleHttpResponseHandler.onSuccess(SimpleHttpResponseHandler.java:70) at io.trino.server.remotetask.SimpleHttpResponseHandler.onSuccess(SimpleHttpResponseHandler.java:27) at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1139) 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:1575) Caused by: java.lang.IllegalArgumentException: Unable to create class io.trino.execution.TaskInfo from JSON response: [io.airlift.jaxrs.JsonParsingException: com.fasterxml.jackson.databind.exc.InvalidDefinitionException: Cannot construct instance of `io.trino.spi.type

java.sql.SQLException: Query failed (#20250312_023921_00032_43ers): Unexpected response from http://172.19.0.4:8081/v1/task/20250312_023921_00032_43ers.2.0.0?summarize

java.sql.SQLException: Query failed (#20250312_023921_00033_43ers): Unexpected response from http://172.19.0.4:8081/v1/task/20250312_023921_00033_43ers.2.0.0?summarize

java.sql.SQLException: Query failed (#20250312_023922_00034_43ers): Unexpected response from http://172.19.0.4:8081/v1/task/20250312_023922_00034_43ers.2.0.0?summarize

java.sql.SQLException: Query failed (#20250312_023922_00035_43ers): Unexpected response from http://172.19.0.4:8081/v1/task/20250312_023922_00035_43ers.2.0.0?summarize

java.sql.SQLException: Query failed (#20250312_023747_00012_qyx8h): Unexpected response from http://172.18.0.5:8081/v1/task/20250312_023747_00012_qyx8h.2.0.0?summarize