From 982c8e59a5f2adf95dbb5199d3c76cde12435626 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Mon, 6 Apr 2020 11:37:52 +0200 Subject: [PATCH] Remove timebucket from clustering column, #399 * originally there because of the materialized view * for old table definitions it must be set * would be difficult to remove it entirely from the table because then we would have to maintain two different insert statements depending on if the table defined the column or not, meaning that we would have to do some fake query when starting up to check if the column is defined --- .../cassandra/journal/CassandraJournalStatements.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/akka/persistence/cassandra/journal/CassandraJournalStatements.scala b/core/src/main/scala/akka/persistence/cassandra/journal/CassandraJournalStatements.scala index e140755e2..436041421 100644 --- a/core/src/main/scala/akka/persistence/cassandra/journal/CassandraJournalStatements.scala +++ b/core/src/main/scala/akka/persistence/cassandra/journal/CassandraJournalStatements.scala @@ -50,7 +50,7 @@ import akka.persistence.cassandra.FutureDone | meta_ser_manifest text, | meta blob, | tags set, - | PRIMARY KEY ((persistence_id, partition_nr), sequence_nr, timestamp, timebucket)) + | PRIMARY KEY ((persistence_id, partition_nr), sequence_nr, timestamp)) | WITH gc_grace_seconds =${journalSettings.gcGraceSeconds} | AND compaction = ${indent(journalSettings.tableCompactionStrategy.asCQL, " ")} """.stripMargin.trim