Member since
03-20-2019
14
Posts
3
Kudos Received
1
Solution
My Accepted Solutions
Title | Views | Posted |
---|---|---|
792 | 11-05-2021 06:09 AM |
12-19-2023
01:03 PM
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!
... View more
Labels:
- Labels:
-
Apache NiFi
11-29-2022
01:36 PM
I found that the schema was defined incorrectly causing an issue. It should be From this "name": "maxApprovedAmount",
"type": "bytes",
"logicalType": "decimal",
"precision": 4,
"scale": 4 to this: "name": "maxApprovedAmount",
"type": {type: "bytes",
"logicalType": "decimal",
"precision": 4,
"scale": 4}
... View more
03-08-2022
12:28 PM
Hi @mr_jahurley , Unfortunately, I can't think of any other option apart from creating a processor that that makes the call directly to the SOAP service. Cheers, André -- Was your question answered? Make sure to mark the answer as the accepted solution. If you find a reply useful, say thanks by clicking on the thumbs up button.
... View more
11-05-2021
06:09 AM
1 Kudo
After adding the jar to the consumeKafkaRecord NAR and bouncing the servers, I am no longer receiving the error. Now I am able to authenticate to Kafka using the GSSAPI SASL mechanism.
... View more