[ https://issues.apache.org/jira/browse/NIFI-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16422699#comment-16422699 ]
ASF GitHub Bot commented on NIFI-4883: -------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/nifi/pull/2600 > 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 > Priority: Major > > 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)