Koji Kawamura created NIFI-4883:
-----------------------------------
Summary: VaridateRecord processor should be able to use different
schema for valid and invalid records
Key: NIFI-4883
URL: https://issues.apache.org/jira/browse/NIFI-4883
Project: Apache NiFi
Issue Type: Bug
Components: Extensions
Reporter: Koji Kawamura
ValidateRecord uses the same record schema for both valid and invalid outgoing
FlowFiles. When the processor writes invalid records using the schema which is
incompatible for the invalid records will not be able to write such records and
throws Exception like this:
{code}
2018-02-15 10:15:09,311 ERROR [Timer-Driven Process Thread-2]
o.a.n.processors.standard.ValidateRecord ValidateRecord[id
=2f5c7438-b406-3811-82f4-4d8122cc87eb]
ValidateRecord[id=2f5c7438-b406-3811-82f4-4d8122cc87eb] failed to process
session
due to java.lang.NumberFormatException: For input string: "01/01/1900": {}
java.lang.NumberFormatException: For input string: "01/01/1900"
at
java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
at java.lang.Long.parseLong(Long.java:589)
at java.lang.Long.parseLong(Long.java:631)
at
org.apache.nifi.serialization.record.util.DataTypeUtils.toLong(DataTypeUtils.java:822)
at
org.apache.nifi.avro.AvroTypeUtil.convertToAvroObject(AvroTypeUtil.java:494)
at
org.apache.nifi.avro.AvroTypeUtil.createAvroRecord(AvroTypeUtil.java:456)
at
org.apache.nifi.avro.WriteAvroResultWithSchema.writeRecord(WriteAvroResultWithSchema.java:60)
at
org.apache.nifi.serialization.AbstractRecordSetWriter.write(AbstractRecordSetWriter.java:59)
at
org.apache.nifi.processors.standard.ValidateRecord.onTrigger(ValidateRecord.java:328)
at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1122)
{code}
ValidateRecord processor should support different schema for invalid FlowFiles.
It could be all String type auto generated schema.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
