Woutifier commented 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).
---------------------------------------------------------------- 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: [email protected] With regards, Apache Git Services
