I have a nifi flow to read from 1 table and write to another.
But when it inserts it thows the error:
PutCassandraRecord[id=bf945542-ef3f-1b23-0000-0000463e16ae] Unable to write the records into Cassandra table due to com.datastax.driver.core.exceptions.InvalidQueryException: You must use conditional updates for serializable writes
- Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: You must use conditional updates for serializable writes: {}
![mr_jahurley_0-1703019283726.png mr_jahurley_0-1703019283726.png](https://community.cloudera.com/t5/image/serverpage/image-id/39212i9F56E85DE24E517D/image-size/medium?v=v2&px=400)
putCassandraRecord processor:
![mr_jahurley_1-1703019372997.png mr_jahurley_1-1703019372997.png](https://community.cloudera.com/t5/image/serverpage/image-id/39213iBDCFA1205CFE7DC9/image-size/medium?v=v2&px=400)
I have tried both serial and local_serial, and none, but all give same error.
I am able to run this if i use putCassandraQL but that means i also have to have a EvaluateJsonPath and a ReplaceText to create the insert statement. I am trying to make it more efficient by using the record aware processor. Any help would be appreciated.
Thank you!