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 12:50:04 UTC
[incubator-pekko-connectors] 01/01: wip
This is an automated email from the ASF dual-hosted git repository.
nvollmar pushed a commit to branch fix-cassandra
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
commit bfa65a5745b3d076aaa5756caf8f94d9b1b4b45e
Author: Nicolas Vollmar <nv...@scaling.ch>
AuthorDate: Tue Mar 14 13:49:56 2023 +0100
wip
---
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..f2b6287fa 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 = 30;
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..d6b4f6969 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(25)
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