[flink] branch release-1.13 updated: [FLINK-25771][cassandra][tests] Raise client timeouts

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
     new 7a0f5ea  [FLINK-25771][cassandra][tests] Raise client timeouts
7a0f5ea is described below

commit 7a0f5ea94d2a80234ff509040caeb4ad39b7306b
Author: Etienne Chauchot <echauc...@apache.org>
AuthorDate: Wed Mar 9 12:26:49 2022 +0100

    [FLINK-25771][cassandra][tests] Raise client timeouts
---
 .../streaming/connectors/cassandra/CassandraConnectorITCase.java   | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
 
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
index 0d33ed7..471e432 100644
--- 
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
+++ 
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
@@ -54,6 +54,7 @@ import com.datastax.driver.core.ConsistencyLevel;
 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 @@ public class CassandraConnectorITCase
                                 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();