Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-7262 Added debug logging for the generated query in PutCassandraRecord. (#5898) 

Signed-off-by: Otto Fowler <otto@apache.org>
This commit is contained in:
Mike 2022-03-25 06:48:57 -04:00 committed by GitHub
parent a75381abbe
commit 2ac90a6441
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/main/java/org/apache/nifi/processors/cassandra/PutCassandraRecord.java
View File

@ -290,6 +290,11 @@ public class PutCassandraRecord extends AbstractCassandraProcessor {
} else { } else {
throw new IllegalArgumentException(format("Statement Type %s is not valid, FlowFile %s", statementType, inputFlowFile)); throw new IllegalArgumentException(format("Statement Type %s is not valid, FlowFile %s", statementType, inputFlowFile));
} }
if (getLogger().isDebugEnabled()) {
getLogger().debug("Query: {}", query.toString());
}
batchStatement.add(query); batchStatement.add(query);
if (recordsAdded.incrementAndGet() == batchSize) { if (recordsAdded.incrementAndGet() == batchSize) {