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: {}
putCassandraRecord processor:
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!