You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2019/04/04 15:26:43 UTC
[nifi] branch master updated: NIFI-6016 PutCassandraRecord batch
size
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 <dn...@googlemail.com>
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 <ma...@apache.org>
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);
}
}