You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Chris Sampson (Jira)" <ji...@apache.org> on 2020/11/25 15:42:00 UTC
[jira] [Created] (NIFI-8045) Avro Schemas should support 'fixed'
field types
Chris Sampson created NIFI-8045:
-----------------------------------
Summary: Avro Schemas should support 'fixed' field types
Key: NIFI-8045
URL: https://issues.apache.org/jira/browse/NIFI-8045
Project: Apache NiFi
Issue Type: Bug
Affects Versions: 1.11.4
Reporter: Chris Sampson
Attachments: avro-fixed.json, avro-fixed.xml
Attempts to use the Avro schema's "fixed" type result in an error:
<code:java>
2020-11-25 15:36:28,187 ERROR [Timer-Driven Process Thread-5] o.a.n.processors.standard.ValidateRecord ValidateRecord[id=0008e1f7-0176-1000-ffff-ffffdc31ab2d] Failed to process StandardFlowFileRecord[uuid=fd2c0bb8-6d2e-4468-a1da-cb862ff33f61,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1606318132008-3243, container=default, section=171], offset=552175, length=47],offset=0,name=fd2c0bb8-6d2e-4468-a1da-cb862ff33f61,size=47]; will route to failure: org.apache.avro.SchemaParseException: "fixed" is not a defined name. The type of the "id" field must be a defined name or a {"type": ...} expression.
org.apache.avro.SchemaParseException: "fixed" is not a defined name. The type of the "id" field must be a defined name or a {"type": ...} expression.
at org.apache.avro.Schema.parse(Schema.java:1265)
at org.apache.avro.Schema$Parser.parse(Schema.java:1032)
at org.apache.avro.Schema$Parser.parse(Schema.java:1020)
at org.apache.nifi.processors.standard.ValidateRecord.getValidationSchema(ValidateRecord.java:478)
at org.apache.nifi.processors.standard.ValidateRecord.onTrigger(ValidateRecord.java:272)
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1176)
at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:213)
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)
at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
<code>
Attached template/flow re-create this with a simply generated JSON content passed to a ValidateRecord processor.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)