cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Atul Saroha <atul.sar...@snapdeal.com>
Subject Re: Achilles not picking cassandra ConsistencyLevel
Date Sat, 12 Mar 2016 11:44:52 GMT
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 <doanduyhai@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.gugnani@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*
>>
>
>

Mime
View raw message