[FLINK-25771][cassandra][tests] Raise client timeouts

pppsunil · Mar 9, 2022 · d0d97cb · d0d97cb
1 parent e35385a
commit d0d97cb
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/...c/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java b/...c/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
@@ -55,6 +55,7 @@
 import com.datastax.driver.core.QueryOptions;
 import com.datastax.driver.core.ResultSet;
 import com.datastax.driver.core.Session;
+import com.datastax.driver.core.SocketOptions;
 import com.datastax.driver.core.exceptions.NoHostAvailableException;
 import com.datastax.driver.mapping.Mapper;
 import com.datastax.driver.mapping.annotations.Table;
@@ -141,6 +142,12 @@ protected Cluster buildCluster(Cluster.Builder builder) {
                                 new QueryOptions()
                                         .setConsistencyLevel(consistencyLevel)
                                         .setSerialConsistencyLevel(ConsistencyLevel.LOCAL_SERIAL))
+                        .withSocketOptions(
+                                new SocketOptions()
+                                        // multiply default timeout by 3
+                                        .setConnectTimeoutMillis(15000)
+                                        // double default timeout
+                                        .setReadTimeoutMillis(24000))
                         .withoutJMXReporting()
                         .withoutMetrics()
                         .build();