Member since
03-13-2018
4
Posts
0
Kudos Received
0
Solutions
12-03-2018
09:40 AM
Hi @Matt Clarke, thank you for your response. The problem was that, for any reason, nifi nodes were not synchronized and each of them was running a different workflow. I have copied the correct flow.xml.gz to all nodes and everything works fine now. Regards.
... View more
11-22-2018
08:23 PM
I have a NiFi deployment with five worker nodes. I launched a workflow that arised this error: 2018-11-22 16:58:06,368 ERROR [Timer-Driven Process Thread-2] o.a.n.processors.standard.ConvertRecord ConvertRecord[id=3ad5bd27-0167-1000-0000-0000256eb90d] Failed to process StandardFlowFileRecord[uuid=ef1f30cd-8d49-41e0-873f-5cfaf197a98d,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1542902286286-47374, container=default, section=270], offset=0, length=31760674],offset=0,name=yelp_business.csv.avro,size=31760674]; will route to failure: org.apache.nifi.processor.exception.ProcessException: org.apache.nifi.schema.access.SchemaNotFoundException: Unable to find schema with name 'inferred.avro.schema'org.apache.nifi.processor.exception.ProcessException: org.apache.nifi.schema.access.SchemaNotFoundException: Unable to find schema with name 'inferred.avro.schema' at org.apache.nifi.processors.standard.AbstractRecordProcessor$1.process(AbstractRecordProcessor.java:132) at org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:2827) at org.apache.nifi.processors.standard.AbstractRecordProcessor.onTrigger(AbstractRecordProcessor.java:109) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1122) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:128) 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: org.apache.nifi.schema.access.SchemaNotFoundException: org.apache.nifi.schema.access.SchemaNotFoundException: Unable to find schema with name 'inferred.avro.schema' at org.apache.nifi.schema.access.SchemaNamePropertyStrategy.getSchema(SchemaNamePropertyStrategy.java:60) at org.apache.nifi.serialization.SchemaRegistryService.getSchema(SchemaRegistryService.java:117) at org.apache.nifi.csv.CSVReader.createRecordReader(CSVReader.java:130) at sun.reflect.GeneratedMethodAccessor77.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.$Proxy130.createRecordReader(Unknown Source) at org.apache.nifi.processors.standard.AbstractRecordProcessor$1.process(AbstractRecordProcessor.java:113) ... 14 common frames omittedCaused by: org.apache.nifi.schema.access.SchemaNotFoundException: Unable to find schema with name 'inferred.avro.schema' at org.apache.nifi.schemaregistry.services.AvroSchemaRegistry.retrieveSchema(AvroSchemaRegistry.java:144) at sun.reflect.GeneratedMethodAccessor78.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.$Proxy131.retrieveSchema(Unknown Source) at org.apache.nifi.schema.access.SchemaNamePropertyStrategy.getSchema(SchemaNamePropertyStrategy.java:53) ... 22 common frames omitted I stopped the workflow, deleted it and restarted NiFi several times, but some of the workers continue showing this error. Thank you.
... View more
Labels:
- Labels:
-
Apache NiFi