You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ot...@apache.org on 2022/03/25 10:49:10 UTC
[nifi] branch main updated: NIFI-7262 Added debug logging for the generated query in PutCassandraRecord. (#5898)
This is an automated email from the ASF dual-hosted git repository.
otto pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 2ac90a6 NIFI-7262 Added debug logging for the generated query in PutCassandraRecord. (#5898)
2ac90a6 is described below
commit 2ac90a644186bd1b78299a4537fd773000363998
Author: Mike <mt...@apache.org>
AuthorDate: Fri Mar 25 06:48:57 2022 -0400
NIFI-7262 Added debug logging for the generated query in PutCassandraRecord. (#5898)
Signed-off-by: Otto Fowler <ot...@apache.org>
---
.../org/apache/nifi/processors/cassandra/PutCassandraRecord.java | 5 +++++
1 file changed, 5 insertions(+)
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 f5e6492..b068f5a 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
@@ -290,6 +290,11 @@ public class PutCassandraRecord extends AbstractCassandraProcessor {
} else {
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);
if (recordsAdded.incrementAndGet() == batchSize) {