Chronos Error while creating Cassandra session and executing a query

[Ahmed Abdelmohsen]

Hi Guys,

I'm using Chrono 2.5.1 with JDK 11 and Cassandra 3.0.4, when starting chronos with Cassandra I'm getting the below issue and I made sure %100 percent there is no any kind of index duplication in the table or metrics keyspace.

I'm using metrics as a keyspace as per Chronos documentation and I have only this index "chronos_job_name_idx" 

CREATE KEYSPACE metrics WITH replication = {'class': 'NetworkTopologyStrategy', 'DC2': '3'}  AND durable_writes = true;

Does anyone faced the same issue while using Chronos with Cassandra ?, Do I missing any extra configuration in Chronos or its something in Cassandra ?

Note: the data is +3M row

WARN Detected request at Consistency Level LOCAL_ONE but the non-DC aware RoundRobinPolicy is in use. It is strongly advised to use DCAwareRoundRobinPolicy if you have multiple DCs/use DC-aware consistency levels (note: this message will only be logged once) (com.datastax.driver.core.policies.RoundRobinPolicy:103)

[2019-08-26 19:18:05,558] WARN Caught exception when creating Cassandra JobStats session (org.apache.mesos.chronos.scheduler.jobs.stats.JobStats:469)

com.datastax.driver.core.exceptions.InvalidQueryException: Index chronos_job_name_idx_1 is a duplicate of existing index chronos_job_name_idx

at com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:50)

at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)

at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)

at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:68)

at org.apache.mesos.chronos.scheduler.jobs.stats.JobStats.getSession(JobStats.scala:444)

at org.apache.mesos.chronos.scheduler.jobs.stats.JobStats.<init>(JobStats.scala:47)

at org.apache.mesos.chronos.scheduler.jobs.stats.JobStats$$FastClassByGuice$$b011c413.newInstance(<generated>)

Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: Index chronos_job_name_idx_1 is a duplicate of existing index chronos_job_name_idx

Thanks,

Ahmed