This is an automated email from the ASF dual-hosted git repository.
mattyb149 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/master by this push:
new d36fa6a NIFI-6016 PutCassandraRecord batch size
d36fa6a is described below
commit d36fa6a210261c147453144ef2fb202745319c84
Author: dnsbtchr <[email protected]>
AuthorDate: Tue Feb 26 11:47:17 2019 +0100
NIFI-6016 PutCassandraRecord batch size
Adds resetting the batch size to fix broken batch processing
Removes empty line
Signed-off-by: Matthew Burgess <[email protected]>
This closes #3337
---
.../java/org/apache/nifi/processors/cassandra/PutCassandraRecord.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/main/java/org/apache/nifi/processors/cassandra/PutCassandraRecord.java
b/nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/main/java/org/apache/nifi/processors/cassandra/PutCassandraRecord.java
index 84016dc..8acc36a 100644
---
a/nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/main/java/org/apache/nifi/processors/cassandra/PutCassandraRecord.java
+++
b/nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/main/java/org/apache/nifi/processors/cassandra/PutCassandraRecord.java
@@ -167,6 +167,7 @@ public class PutCassandraRecord extends
AbstractCassandraProcessor {
if (recordsAdded.incrementAndGet() == batchSize) {
connectionSession.execute(batchStatement);
batchStatement.clear();
+ recordsAdded.set(0);
}
}
