cassandra: adds log statement to help debug schema install failure (#…

…3740) Signed-off-by: Adrian Cole <adrian@tetrate.io>
openzipkin · Feb 29, 2024 · e9b55ef · e9b55ef
1 parent 9acae64
commit e9b55ef
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/zipkin-storage/cassandra/src/main/java/zipkin2/storage/cassandra/Schema.java b/zipkin-storage/cassandra/src/main/java/zipkin2/storage/cassandra/Schema.java
@@ -101,6 +101,7 @@ static Version ensureVersion(com.datastax.oss.driver.api.core.metadata.Metadata
       }
     }
     if (version == null) throw new RuntimeException("No nodes in the cluster");
+    LOG.info("Detected Cassandra version {}", version);
     return version;
   }
 

diff --git a/zipkin-storage/cassandra/src/test/java/zipkin2/storage/cassandra/ITEnsureSchema.java b/zipkin-storage/cassandra/src/test/java/zipkin2/storage/cassandra/ITEnsureSchema.java
@@ -53,6 +53,13 @@ abstract class ITEnsureSchema extends ITStorage<CassandraStorage> {
   abstract CqlSession session();
 
   @Test void installsKeyspaceWhenMissing() {
+    Schema.ensureExists(storage.keyspace, true, session());
+
+    KeyspaceMetadata metadata = session().getMetadata().getKeyspace(storage.keyspace).get();
+    assertThat(metadata).isNotNull();
+  }
+
+  @Test void installsKeyspaceWhenMissing_searchDisabled() {
     Schema.ensureExists(storage.keyspace, false, session());
 
     KeyspaceMetadata metadata = session().getMetadata().getKeyspace(storage.keyspace).get();