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 <[email protected]>
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 <[email protected]>
---
.../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) {
