[nifi] branch main updated: NIFI-11234: Fix RecordWriter NPE in QuerySalesforceObject

[tpalfy]

This is an automated email from the ASF dual-hosted git repository.

tpalfy 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 9ea0fe7b3d NIFI-11234: Fix RecordWriter NPE in QuerySalesforceObject
9ea0fe7b3d is described below

commit 9ea0fe7b3db3f04673a28ed34455fd3907c15fe1
Author: Lehel Boér <lehe...@hotmail.com>
AuthorDate: Wed Mar 1 14:53:08 2023 +0100

    NIFI-11234: Fix RecordWriter NPE in QuerySalesforceObject
    
    This closes #6997.
    
    Signed-off-by: Tamas Palfy <tpa...@apache.org>
---
 .../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";