Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-11234: Fix RecordWriter NPE in QuerySalesforceObject 

This closes #6997.

Signed-off-by: Tamas Palfy <tpalfy@apache.org>
This commit is contained in:
Lehel Boér 2023-03-01 14:53:08 +01:00 committed by Tamas Palfy
parent 60c02225d5
commit 9ea0fe7b3d
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/QuerySalesforceObject.java
View File

@ -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";