Hello

Can you share a template of the flow configuration?

Thanks

On Sat, Aug 5, 2017 at 6:13 PM Frederik <frederik.schm...@qrious.co.nz>
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.
>

Reply via email to