From 9ea0fe7b3db3f04673a28ed34455fd3907c15fe1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lehel=20Bo=C3=A9r?= Date: Wed, 1 Mar 2023 14:53:08 +0100 Subject: [PATCH] NIFI-11234: Fix RecordWriter NPE in QuerySalesforceObject This closes #6997. Signed-off-by: Tamas Palfy --- .../nifi/processors/salesforce/QuerySalesforceObject.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/QuerySalesforceObject.java b/nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/QuerySalesforceObject.java index edea559560..77a82f0b03 100644 --- a/nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/QuerySalesforceObject.java +++ b/nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/QuerySalesforceObject.java @@ -166,7 +166,7 @@ public class QuerySalesforceObject extends AbstractProcessor { .displayName("Record Writer") .description("Service used for writing records returned from the Salesforce REST API") .identifiesControllerService(RecordSetWriterFactory.class) - .required(false) + .required(true) .dependsOn(QUERY_TYPE, PROPERTY_BASED_QUERY) .build(); @@ -240,6 +240,7 @@ public class QuerySalesforceObject extends AbstractProcessor { static final Relationship REL_FAILURE = new Relationship.Builder() .name("failure") .description("The input flowfile gets sent to this relationship when the query fails.") + .autoTerminateDefault(true) .build(); private static final String LAST_AGE_FILTER = "last_age_filter";