You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by cg...@apache.org on 2021/08/08 01:41:22 UTC

[drill] branch master updated: DRILL-7982: Timed out waiting for container port to open (#2287)

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

cgivre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git


The following commit(s) were added to refs/heads/master by this push:
     new 3c092b3  DRILL-7982: Timed out waiting for container port to open (#2287)
3c092b3 is described below

commit 3c092b387fc376d690dc53ff6d37a9b26f1e75e6
Author: luoc <lu...@apache.org>
AuthorDate: Sun Aug 8 09:41:13 2021 +0800

    DRILL-7982: Timed out waiting for container port to open (#2287)
---
 .../apache/drill/exec/store/cassandra/TestCassandraSuit.java   | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/contrib/storage-cassandra/src/test/java/org/apache/drill/exec/store/cassandra/TestCassandraSuit.java b/contrib/storage-cassandra/src/test/java/org/apache/drill/exec/store/cassandra/TestCassandraSuit.java
index 60d21c7..9009ba7 100644
--- a/contrib/storage-cassandra/src/test/java/org/apache/drill/exec/store/cassandra/TestCassandraSuit.java
+++ b/contrib/storage-cassandra/src/test/java/org/apache/drill/exec/store/cassandra/TestCassandraSuit.java
@@ -17,6 +17,9 @@
  */
 package org.apache.drill.exec.store.cassandra;
 
+import java.time.Duration;
+import java.util.concurrent.atomic.AtomicInteger;
+
 import org.apache.drill.categories.SlowTest;
 import org.apache.drill.test.BaseTest;
 import org.junit.AfterClass;
@@ -26,8 +29,6 @@ import org.junit.runner.RunWith;
 import org.junit.runners.Suite;
 import org.testcontainers.containers.CassandraContainer;
 
-import java.util.concurrent.atomic.AtomicInteger;
-
 @Category(SlowTest.class)
 @RunWith(Suite.class)
 @Suite.SuiteClasses({CassandraComplexTypesTest.class, CassandraPlanTest.class, CassandraQueryTest.class})
@@ -65,7 +66,10 @@ public class TestCassandraSuit extends BaseTest {
 
   private static void startCassandra() {
     cassandra = new CassandraContainer<>("cassandra")
-        .withInitScript("queries.cql");
+      .withInitScript("queries.cql")
+      .withStartupTimeout(Duration.ofMinutes(2))
+      .withEnv("CASSANDRA_SNITCH", "GossipingPropertyFileSnitch") // Tune Cassandra options for faster startup
+      .withEnv("JVM_OPTS", "-Dcassandra.skip_wait_for_gossip_to_settle=0 -Dcassandra.initial_token=0");
     cassandra.start();
   }
 }