You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/03/09 11:28:10 UTC
[flink] branch release-1.14 updated: [FLINK-25771][cassandra][tests] Raise client timeouts
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.14 by this push:
new af019cc [FLINK-25771][cassandra][tests] Raise client timeouts
af019cc is described below
commit af019cc5dad5811925a51e906b9de8a8d2c7014e
Author: Etienne Chauchot <ec...@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 09212c5..924c684 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
@@ -55,6 +55,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();