Hello Can you share a template of the flow configuration?
Thanks On Sat, Aug 5, 2017 at 6:13 PM Frederik <[email protected]> wrote: > Hi, > > thanks. I agree in theory this should work without any trouble. But I get > the same error "SchemaNotFoundException" with > Embedded Avro Schema (see exception below) and Use 'Schema Text' > > Also my Flow file has the avro.schema property see below. > > Any ideas how I could overcome this problem or what I could do wrongly. > > thanks > Frederik > > ####### FLOW File #### > > Obj^A^B^Vavro.schema<8a>^B{"type":"record","name":"customer_crm_summary","namespace":"any.data","fields":[{"name":"device_tac_code","type":["null","string"]}]} > ####### > > > ##### Exception after Use Embedded Avro Schema#### > 2017-08-06 12:26:13,276 ERROR [Timer-Driven Process Thread-3] > o.a.n.processors.standard.ConvertRecord > ConvertRecord[id=aa3816d3-015d-1000-957e-603e093ba845] Failed to convert > records for > > StandardFlowFileRecord[uuid=e5aab5ef-f1df-40d5-bb49-1f44b95c9c2b,claim=StandardContentClaim > [resourceClaim=StandardResourceClaim[id=1501979172410-783, > container=default, section=783], offset=0, > length=4091297],offset=0,name=8117272233752224,size=4091128]; will route to > failure: org.apache.nifi.schema.access.SchemaNotFoundException: FlowFile > did > not contain appropriate attributes to determine Schema Text > org.apache.nifi.schema.access.SchemaNotFoundException: FlowFile did not > contain appropriate attributes to determine Schema Text > at > > org.apache.nifi.schema.access.AvroSchemaTextStrategy.getSchema(AvroSchemaTextStrategy.java:46) > at > > org.apache.nifi.serialization.SchemaRegistryService.getSchema(SchemaRegistryService.java:106) > at > > org.apache.nifi.csv.CSVRecordSetWriter.createWriter(CSVRecordSetWriter.java:73) > at sun.reflect.GeneratedMethodAccessor705.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.$Proxy76.createWriter(Unknown Source) > at > > org.apache.nifi.processors.standard.ConvertRecord.onTrigger(ConvertRecord.java:128) > at > > org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) > at > > org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1118) > 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) > > ##### > > thanks > Frederik > > > > > -- > View this message in context: > http://apache-nifi-developer-list.39713.n7.nabble.com/Avro-Reader-reading-from-FlowFile-throws-SchemaNotFoundException-tp16574p16584.html > Sent from the Apache NiFi Developer List mailing list archive at > Nabble.com. >
