Options
- Subscribe to RSS Feed
- Mark Question as New
- Mark Question as Read
- Float this Question for Current User
- Bookmark
- Subscribe
- Mute
- Printer Friendly Page
Nifi PutCassandraRecord - How to use conditional updates for serializable writes: {}
Labels:
- Labels:
-
Apache NiFi
Contributor
Created ‎12-19-2023 01:03 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
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!
1 REPLY 1
Contributor
Created ‎09-12-2024 04:11 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
Trying to bring this back up to see if anyone has a suggestion? Thank you.
