set short GC grace period to mop up tombstones quickly as there will be lots of deletes in the queue message tables
diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/impl/QueueMessageSerializationImpl.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/impl/QueueMessageSerializationImpl.java index fb49825..cb1f476 100644 --- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/impl/QueueMessageSerializationImpl.java +++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/impl/QueueMessageSerializationImpl.java
@@ -89,7 +89,14 @@ "queued_at bigint, " + "inflight_at bigint, " + "PRIMARY KEY ((queue_name, region, shard_id), queue_message_id ) " + - ") WITH CLUSTERING ORDER BY (queue_message_id ASC); "; + ") WITH CLUSTERING ORDER BY (queue_message_id ASC) AND " + + "gc_grace_seconds = 60 AND " + + "compaction = {'class': " + "'LeveledCompactionStrategy', " + + "'sstable_size_in_mb': 5, " + + "'tombstone_compaction_interval': 60, " + + "'tombstone_threshold': 0.05, " + + "'unchecked_tombstone_compaction': true" + + "};"; static final String MESSAGES_INFLIGHT = "CREATE TABLE IF NOT EXISTS messages_inflight ( " + @@ -101,7 +108,14 @@ "queued_at bigint, " + "inflight_at bigint, " + "PRIMARY KEY ((queue_name, region, shard_id), queue_message_id ) " + - ") WITH CLUSTERING ORDER BY (queue_message_id ASC); "; + ") WITH CLUSTERING ORDER BY (queue_message_id ASC) AND " + + "gc_grace_seconds = 60 AND " + + "compaction = {'class': " + "'LeveledCompactionStrategy', " + + "'sstable_size_in_mb': 5, " + + "'tombstone_compaction_interval': 60, " + + "'tombstone_threshold': 0.05, " + + "'unchecked_tombstone_compaction': true" + + "};"; static final String MESSAGE_DATA = "CREATE TABLE IF NOT EXISTS message_data ( " +