This is an automated email from the ASF dual-hosted git repository. joewitt pushed a commit to branch support/nifi-1.16 in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 79b375fc834262981987634a02a05b8e668f6885 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 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) {
