[
https://issues.apache.org/jira/browse/NIFI-3682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975729#comment-15975729
]
ASF GitHub Bot commented on NIFI-3682:
--------------------------------------
Github user joewitt commented on the issue:
https://github.com/apache/nifi/pull/1682
and these
16:17:32 PDTERROR552176d0-84dc-3e8f-f567-345d11834c65
QueryRecord[id=552176d0-84dc-3e8f-f567-345d11834c65] Unable to query
StandardFlowFileRecord[uuid=27127114-2059-4269-996b-6ea097d6db70,claim=StandardContentClaim
[resourceClaim=StandardResourceClaim[id=1492643577664-1, container=default,
section=1], offset=19874,
length=203],offset=0,name=nifi-app.19874-20077.log,size=203] due to
org.apache.nifi.schema.access.SchemaNotFoundException:
java.lang.NullPointerException:
org.apache.nifi.schema.access.SchemaNotFoundException:
java.lang.NullPointerException
2017-04-19 16:18:02,878 ERROR [Timer-Driven Process Thread-2]
o.a.nifi.processors.standard.QueryRecord
QueryRecord[id=552176d0-84dc-3e8f-f567-345d11834c65] Unable to query
StandardFlowFileRecord[uuid=27127114-2059-4269-996b-6ea097d6db70,claim=StandardContentClaim
[resourceClaim=StandardResourceClaim[id=1492643577664-1, container=default,
section=1], offset=19874,
length=203],offset=0,name=nifi-app.19874-20077.log,size=203] due to
org.apache.nifi.schema.access.SchemaNotFoundException:
java.lang.NullPointerException: {}
org.apache.nifi.schema.access.SchemaNotFoundException:
java.lang.NullPointerException
at
org.apache.nifi.schema.access.AvroSchemaTextStrategy.getSchema(AvroSchemaTextStrategy.java:52)
at
org.apache.nifi.serialization.SchemaRegistryService.getSchema(SchemaRegistryService.java:140)
at
org.apache.nifi.json.JsonRecordSetWriter.createWriter(JsonRecordSetWriter.java:68)
at sun.reflect.GeneratedMethodAccessor348.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:89)
at com.sun.proxy.$Proxy112.createWriter(Unknown Source)
at
org.apache.nifi.processors.standard.QueryRecord.onTrigger(QueryRecord.java:257)
at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1115)
at
org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:144)
at
org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47)
at
org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132)
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:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.NullPointerException: null
at org.apache.avro.Schema.parse(Schema.java:1225)
at org.apache.avro.Schema$Parser.parse(Schema.java:1032)
at org.apache.avro.Schema$Parser.parse(Schema.java:1020)
at
org.apache.nifi.schema.access.AvroSchemaTextStrategy.getSchema(AvroSchemaTextStrategy.java:49)
... 20 common frames omitted
> Add "Schema Access Strategy" to Record Readers and Writers
> ----------------------------------------------------------
>
> Key: NIFI-3682
> URL: https://issues.apache.org/jira/browse/NIFI-3682
> Project: Apache NiFi
> Issue Type: Improvement
> Components: Extensions
> Reporter: Mark Payne
> Assignee: Mark Payne
> Fix For: 1.2.0
>
>
> Currently the record readers are mostly configured with a Schema Registry
> service and the name of the schema. We should instead allow user to choose
> one of several strategies for determining the schema: Schema Registry +
> schema.name attribute, Schema Registry + identifier and version embedded at
> start of record/stream, avro.schema attribute, embedded schema for cases like
> Avro where the schema can be embedded in the content itself.
> On the writer side, we should also expose these options in order to convey
> the schema information to others.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
