This is an automated email from the ASF dual-hosted git repository. tpalfy pushed a commit to branch support/nifi-1.x in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 203de77bb980e3168d6b0485f5af6575b25c2381 Author: Lehel Boér <[email protected]> AuthorDate: Wed Mar 1 14:53:08 2023 +0100 NIFI-11234: Fix RecordWriter NPE in QuerySalesforceObject This closes #6997. Signed-off-by: Tamas Palfy <[email protected]> --- .../org/apache/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";
