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

mr_jahurley — Tue, 19 Dec 2023 21:03:56 GMT

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!

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

mr_jahurley — Thu, 12 Sep 2024 23:11:08 GMT

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

question Nifi PutCassandraRecord - How to use conditional updates for serializable writes: {} in Support Questions

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

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