[
https://issues.apache.org/jira/browse/NIFI-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ben updated NIFI-4228:
----------------------
Description:
the new PutDatabaseRecord processor currently has a bug that fails to support
the 'Ignore Unmatched Fields' of property 'Unmatched Field Behavior', when the
source AVRO records have fields that don't exist in the insertion destination
table and the property 'Unmatched Field Behavior' is set to 'Ignore unmatched
fields', then it will result in error instead of ignoring the extra fields in
the source.
The fix is actually quite easy, in line 785 of file
PutDatabaseRecord.java(method generateInsert), replace 'fieldCount' with
'includedColumns.size()'.
was:
the new PutDatabaseRecord processor currently has a bug that fails to support
the 'Unmatched Field Behavior', when the source AVRO records have more fields
than the insertion destination table and the property 'Unmatched Field
Behavior' is set to 'Ignore unmatched fields', then it will result in error
instead of ignoring the extra fields in the source.
The fix is actually quite easy, in line 785 of file
PutDatabaseRecord.java(method generateInsert), replace 'fieldCount' with
'includedColumns.size()'.
> PutDatabaseRecord Processor fail to support 'Ignore Unmatched Fields'
> ---------------------------------------------------------------------
>
> Key: NIFI-4228
> URL: https://issues.apache.org/jira/browse/NIFI-4228
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Affects Versions: 1.3.0
> Environment: in NIFI 1.3.0
> Reporter: ben
> Priority: Minor
> Labels: easyfix
>
> the new PutDatabaseRecord processor currently has a bug that fails to support
> the 'Ignore Unmatched Fields' of property 'Unmatched Field Behavior', when
> the source AVRO records have fields that don't exist in the insertion
> destination table and the property 'Unmatched Field Behavior' is set to
> 'Ignore unmatched fields', then it will result in error instead of ignoring
> the extra fields in the source.
> The fix is actually quite easy, in line 785 of file
> PutDatabaseRecord.java(method generateInsert), replace 'fieldCount' with
> 'includedColumns.size()'.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
