Hi, could it be consistency level issue? If you use ONE for reads and writes, might be that sometimes you don't get what you are writing.
See: https://docs.datastax.com/en/cassandra/2.0/cassandra/dml/dml_config_consistency_c.html Br, Hannu 2016-04-27 20:41 GMT+03:00 Siddharth Verma <verma.siddha...@snapdeal.com>: > Hi, > I dont know, if someone has faced this problem or not. > I am running a job where some data is loaded from cassandra table. From > that data, i make some insert and delete statements. > and execute it (using forEach) > > Code snippet: > boolean deleteStatus= connector.openSession().execute(delete).wasApplied(); > boolean insertStatus = > connector.openSession().execute(insert).wasApplied(); > System.out.println(delete+":"+deleteStatus); > System.out.println(insert+":"+insertStatus); > > When i run it locally, i see the respective results in the table. > > However when i run it on a cluster, sometimes the result is displayed and > sometime the changes don't take place. > I saw the stdout from web-ui of spark, and the query along with true was > printed for both the queries. > > I can't understand, what could be the issue. > > Any help would be appreciated. > > Thanks, > Siddharth Verma >
