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
