It's better to post your question at the dedicated mailing list for Achilles: https://groups.google.com/forum/?hl=fr#!forum/cassandra-achilles
To enable to help you further, please provide some DML logs at runtime: https://github.com/doanduyhai/Achilles/wiki/Statements-Logging-and-Tracing#global-statements-logging On Sat, Mar 12, 2016 at 8:49 AM, Raman Gugnani <raman.gugn...@snapdeal.com> wrote: > Hi All, > > We are using achilles in our code. We are setting Consistency level as > below, but is not being set.Does anyone else have faced this issue.We have > three nodes in our cluster. > > PoolingOptions poolingOptions = new PoolingOptions(); > poolingOptions.setCoreConnectionsPerHost(HostDistance.REMOTE, > Integer.parseInt(env.getProperty("cassandra.core.connections.host"))); > poolingOptions.setMaxConnectionsPerHost(HostDistance.REMOTE, > Integer.parseInt(env.getProperty("cassandra.max.connections.host"))); > poolingOptions.setMaxRequestsPerConnection(HostDistance.REMOTE, > Integer.parseInt(env.getProperty("cassandra.max.requests.connections"))); > > Cluster.Builder > builder=Cluster.builder().addContactPoints(env.getProperty("cassandra.host")).withPoolingOptions(poolingOptions).withPort( > > Integer.parseInt(env.getProperty("cassandra.cql.port"))).withClusterName(CLUSTER_NAME); > if(env.getProperty("cassandra.cql.user") != null){ > builder.withCredentials(env.getProperty("cassandra.cql.user"), > env.getProperty("cassandra.cql.password")); > } > Cluster cluster = builder.build(); > > QueryLogger queryLogger = > QueryLogger.builder().withConstantThreshold(300).withMaxQueryStringLength(1000).build(); > cluster.register(queryLogger); > String clRead = env.getProperty("cassandra.consistencylevel.read"); > String clWrite = > env.getProperty("cassandra.consistencylevel.write"); > LOG.info("Starting cassandra cluster for host {} and port {} ", > env.getProperty("cassandra.host"), env.getProperty("cassandra.cql.port")); > LOG.info(" clRead {} and clWrite {}", clRead, clWrite); > final ManagerFactory factory = > ManagerFactoryBuilder.builder(cluster).withDefaultWriteConsistency( > clWrite == null ? ConsistencyLevel.EACH_QUORUM : > ConsistencyLevel.valueOf(clWrite)).withDefaultReadConsistency( > clRead == null ? ConsistencyLevel.ONE : > ConsistencyLevel.valueOf(clRead)).build(); > return factory; > > -- > Thanks & Regards > > Raman Gugnani > *Senior Software Engineer | CaMS* > M: +91 8588892293 | T: 0124-6600000 | EXT: 14255 > ASF Centre A | 2nd Floor | CA-2130 | Udyog Vihar Phase IV | > Gurgaon | Haryana | India > > *Disclaimer:* This communication is for the sole use of the addressee and > is confidential and privileged information. If you are not the intended > recipient of this communication, you are prohibited from disclosing it and > are required to delete it forthwith. Please note that the contents of this > communication do not necessarily represent the views of Jasper Infotech > Private Limited ("Company"). E-mail transmission cannot be guaranteed to be > secure or error-free as information could be intercepted, corrupted, lost, > destroyed, arrive late or incomplete, or contain viruses. The Company, > therefore, does not accept liability for any loss caused due to this > communication. *Jasper Infotech Private Limited, Registered Office: 1st > Floor, Plot 238, Okhla Industrial Estate, New Delhi - 110020 INDIA CIN: > U72300DL2007PTC168097* >
