The changes made are fairly simple, but they help in rolling back the transactions in case of error. Please let me know if you have any question. I am reachable on suyogbarve@gmail.com

Propagate the exception in CassandraWriteWork to let CassandraSink
rollback the transaction in case of exceptions