You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by nv...@apache.org on 2023/03/14 13:24:48 UTC
[incubator-pekko-connectors] branch main updated: Increases timeout to stabilize build (#48)
This is an automated email from the ASF dual-hosted git repository.
nvollmar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 36a53c42f Increases timeout to stabilize build (#48)
36a53c42f is described below
commit 36a53c42fe10926fc45fcafa131e6b891047f5d6
Author: Nicolas Vollmar <nv...@gmail.com>
AuthorDate: Tue Mar 14 14:24:43 2023 +0100
Increases timeout to stabilize build (#48)
---
cassandra/src/test/java/docs/javadsl/CassandraTestHelper.java | 2 +-
.../pekko/stream/connectors/cassandra/scaladsl/CassandraLifecycle.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/cassandra/src/test/java/docs/javadsl/CassandraTestHelper.java b/cassandra/src/test/java/docs/javadsl/CassandraTestHelper.java
index 56b23c425..c24e6655b 100644
--- a/cassandra/src/test/java/docs/javadsl/CassandraTestHelper.java
+++ b/cassandra/src/test/java/docs/javadsl/CassandraTestHelper.java
@@ -65,7 +65,7 @@ public class CassandraTestHelper {
}
public static <T> T await(Future<T> future) {
- int seconds = 10;
+ int seconds = 20;
try {
return Await.result(future, FiniteDuration.create(seconds, TimeUnit.SECONDS));
} catch (InterruptedException e) {
diff --git a/cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraLifecycle.scala b/cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraLifecycle.scala
index c60899add..4f67f1abc 100644
--- a/cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraLifecycle.scala
+++ b/cassandra/src/test/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraLifecycle.scala
@@ -44,7 +44,7 @@ trait CassandraLifecycleBase {
execute(session, statements.map(stmt => SimpleStatement.newInstance(stmt)))
}
- private val keyspaceTimeout = java.time.Duration.ofSeconds(10)
+ private val keyspaceTimeout = java.time.Duration.ofSeconds(15)
def createKeyspace(session: CassandraSession, name: String): Future[Done] = {
session.executeWrite(
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org