Just replied. The behavior is normal, when using TypedQuery or NativeQuery, since you are crafting the query yourself, it is your responsibility to set query options (consistency, timestamp, retry policy ....) on the native Statement object. Achilles only executes the statement and map native Rows objects back to entities
On Sat, Mar 12, 2016 at 12:44 PM, Atul Saroha <atul.sar...@snapdeal.com> wrote: > 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* >>> >> >> >
