You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2022/07/05 12:24:00 UTC
[jira] [Comment Edited] (FLINK-28198) CassandraConnectorITCase fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562526#comment-17562526 ]
Etienne Chauchot edited comment on FLINK-28198 at 7/5/22 12:23 PM:
-------------------------------------------------------------------
Hi [~martijnvisser] I was busy on an urgent matter, I just started to take a look. Seems like createTable fails with timeout but not the first create keyspace request. Raising once again the timeouts in the cassandra cluster does not seem to be the correct move here. All the CQL requests are launched synchronously but there might be residual load on the cluster. I'll try to find a cluster internal metric and block on its status to ensure the load is ok before starting new tests
was (Author: echauchot):
Hi [~martijnvisser] I was busy on an urgent matter, I just started to take a look. Seems like createTable fails with timeout but not the first create keyspace request. Raising once again the timeouts in the cassandra cluster does not seem to be the correct move here. All the CQL requests are launched synchronously but there might be residual load on the cluster. I'll try to find a cluster internal metric and block on its status to ensure the load is ok before new tests (in the Before method)
> CassandraConnectorITCase fails with timeout
> -------------------------------------------
>
> Key: FLINK-28198
> URL: https://issues.apache.org/jira/browse/FLINK-28198
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Cassandra
> Affects Versions: 1.16.0
> Reporter: Martijn Visser
> Assignee: Etienne Chauchot
> Priority: Critical
> Labels: test-stability
> Fix For: 1.16.0
>
>
> {code:java}
> Jun 22 07:57:37 [ERROR] org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase.testRaiseCassandraRequestsTimeouts Time elapsed: 12.067 s <<< ERROR!
> Jun 22 07:57:37 com.datastax.driver.core.exceptions.OperationTimedOutException: [/172.17.0.1:59915] Timed out waiting for server response
> Jun 22 07:57:37 at com.datastax.driver.core.exceptions.OperationTimedOutException.copy(OperationTimedOutException.java:43)
> Jun 22 07:57:37 at com.datastax.driver.core.exceptions.OperationTimedOutException.copy(OperationTimedOutException.java:25)
> Jun 22 07:57:37 at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:35)
> Jun 22 07:57:37 at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:293)
> Jun 22 07:57:37 at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:58)
> Jun 22 07:57:37 at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:39)
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=37037&view=logs&j=4eda0b4a-bd0d-521a-0916-8285b9be9bb5&t=2ff6d5fa-53a6-53ac-bff7-fa524ea361a9&l=13736
--
This message was sent by Atlassian Jira
(v8.20.10#820010)