From 2ac90a644186bd1b78299a4537fd773000363998 Mon Sep 17 00:00:00 2001 From: Mike Date: Fri, 25 Mar 2022 06:48:57 -0400 Subject: [PATCH] NIFI-7262 Added debug logging for the generated query in PutCassandraRecord. (#5898) Signed-off-by: Otto Fowler --- .../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 f5e6492fe8..b068f5ad81 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) {