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