diff --git a/src/main/scala/org/apache/mesos/chronos/scheduler/jobs/stats/JobStats.scala b/src/main/scala/org/apache/mesos/chronos/scheduler/jobs/stats/JobStats.scala index dfb83fbf4..e150485e9 100644 --- a/src/main/scala/org/apache/mesos/chronos/scheduler/jobs/stats/JobStats.scala +++ b/src/main/scala/org/apache/mesos/chronos/scheduler/jobs/stats/JobStats.scala @@ -563,6 +563,7 @@ class JobStats @Inject()(clusterBuilder: Option[Cluster.Builder], config: Cassan query.setConsistencyLevel(ConsistencyLevel.valueOf(config.cassandraConsistency())) .asInstanceOf[RegularStatement] + query.using(QueryBuilder.ttl(config.cassandraTtl())) session.executeAsync(query) }