From a2ac1e8f6fc077243bad869d5e3b9e942a19d3d8 Mon Sep 17 00:00:00 2001 From: Justin Date: Wed, 28 Mar 2018 23:58:24 +0900 Subject: [PATCH] Support ttl when query to cassandra --- .../org/apache/mesos/chronos/scheduler/jobs/stats/JobStats.scala | 1 + 1 file changed, 1 insertion(+) 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) }