Skip to content
Permalink
Browse files
Fix flaky timeouts coming from concurrent view builds and schema modi…
…fication

Patch by Adam Holmberg, reviewed by Berenguer Blasi and brandonwilliams
for CASSANDRA-15993
  • Loading branch information
aholmberg authored and driftx committed Oct 1, 2020
1 parent e4e8d94 commit 1789213ee00a05b3686858b3a22dc8c2d26fc837
Showing 1 changed file with 4 additions and 3 deletions.
@@ -209,13 +209,14 @@ def create_views(session, views, keyspace="ks1"):
logger.debug("create view")
for view in range(views):
session.execute("CREATE MATERIALIZED VIEW mv{} AS SELECT * FROM t "
"WHERE k IS NOT NULL AND c IS NOT NULL PRIMARY KEY (c,k)".format(view))
for view in range(views):
"WHERE k IS NOT NULL AND c IS NOT NULL PRIMARY KEY (c,k)".format(view),
timeout=60)
self._wait_for_view(keyspace, "mv{}".format(view))

def drop_keyspace(session, keyspace="ks1"):
logger.debug("drop keyspace {}".format(keyspace))
session.execute("DROP KEYSPACE IF EXISTS {}".format(keyspace))
session.execute("DROP KEYSPACE IF EXISTS {}".format(keyspace),
timeout=60)

def drop_views(session, views):
logger.debug("drop all views")

0 comments on commit 1789213

Please sign in to comment.