Posted on below link. https://groups.google.com/forum/#!topic/cassandra-achilles/pSTcwVshMYE
Thanks --------------------------------------------------------------------------------------------------------------------- Atul Saroha *Sr. Software Engineer* *M*: +91 8447784271 *T*: +91 124-415-6069 *EXT*: 12369 Plot # 362, ASF Centre - Tower A, Udyog Vihar, Phase -4, Sector 18, Gurgaon, Haryana 122016, INDIA On Sat, Mar 12, 2016 at 4:00 PM, DuyHai Doan <doanduy...@gmail.com> wrote: > 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* >> > >
