You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by GitBox <gi...@apache.org> on 2020/01/29 17:07:23 UTC

[GitHub] [nifi] Woutifier edited a comment on issue #3977: NIFI-7007 Add update functionality to the PutCassandraRecord processor.

Woutifier edited a comment on issue #3977: NIFI-7007 Add update functionality to the PutCassandraRecord processor.
URL: https://github.com/apache/nifi/pull/3977#issuecomment-579858760
 
 
   > I tested it with a running Cassandra and it seems there are some issue.
   > The `PutCassandraRecord` uses batch statements but it seems you cannot use that for `counter` type columns:
   > 
   > ```java
   > ore.exceptions.InvalidQueryException: Cannot include a counter statement in a logged batch: com.datastax.driver.core.exceptions.InvalidQueryException: Cannot include a counter statement in a logged batch
   > com.datastax.driver.core.exceptions.InvalidQueryException: Cannot include a counter statement in a logged batch
   >         at com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:50)
   >         at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
   >         at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)
   >         at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:68)
   >         at org.apache.nifi.processors.cassandra.PutCassandraRecord.onTrigger(PutCassandraRecord.java:285)
   > ```
   > 
   > Maybe we don't want to start supporting counters, but `Increment` and `Decrement` can only be used for those. And if we remove those, the UPDATE SET is basically identical to an INSERT.
   
   Hey @tpalfy 
   
   COUNTER is just another batch statement type, which I've already added. Just make sure that you select COUNTER in the Batch Statement Type (can also be supplied via cql.batch.statement.type if required).
   
   (posted from my personal account as I don't have access to the other one from home)

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services