diff --git a/plugin/trino-cassandra/src/test/java/io/trino/plugin/cassandra/TestCassandraTypeMapping.java b/plugin/trino-cassandra/src/test/java/io/trino/plugin/cassandra/TestCassandraTypeMapping.java index 5cd53d8d91fb..55698b84bc88 100644 --- a/plugin/trino-cassandra/src/test/java/io/trino/plugin/cassandra/TestCassandraTypeMapping.java +++ b/plugin/trino-cassandra/src/test/java/io/trino/plugin/cassandra/TestCassandraTypeMapping.java @@ -14,6 +14,7 @@ package io.trino.plugin.cassandra; import com.google.common.collect.ImmutableList; +import com.google.common.collect.ImmutableMap; import io.trino.Session; import io.trino.plugin.cassandra.TestCassandraTable.ColumnDefinition; import io.trino.spi.type.RowType.Field; @@ -140,7 +141,11 @@ protected QueryRunner createQueryRunner() { server = closeAfterClass(new CassandraServer()); session = server.getSession(); - return CassandraQueryRunner.builder(server).build(); + return CassandraQueryRunner.builder(server) + .addConnectorProperties(ImmutableMap.builder() + .put("cassandra.client.read-timeout", "30s") + .buildOrThrow()) + .build(); } @AfterAll