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 index 33bc1fef996..152538c5a24 100644 --- 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 index e9a4095bb67..7cca2e5b5c5 100644 --- 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 { 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();