Support Questions

Find answers, ask questions, and share your expertise

Nifi PutCassandraRecord - How to use conditional updates for serializable writes: {}

avatar
Contributor

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

putCassandraRecord processor: 

mr_jahurley_1-1703019372997.png

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!

 

1 REPLY 1

avatar
Contributor

Trying to bring this back up to see if anyone has a suggestion? Thank you.