2018-05-23 10:47:47,129 ERROR [Timer-Driven Process Thread-1] o.a.n.processors.standard.ConvertRecord ConvertRecord[id=a60eb13a-8b9f-301b-004f-482198546e4c] Failed to process StandardFlowFileRecord[uuid=5f8bc9bc-6a82-45d8-befc-8fab5c0cc6fc,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1526973092296-3, container=default, section=3], offset=8554, length=4164],offset=0,name=users.csv,size=4164]; will route to failure: org.apache.nifi.processor.exception.ProcessException: java.io.IOException: Failed to retrieve schema with name 'users' org.apache.nifi.processor.exception.ProcessException: java.io.IOException: Failed to retrieve schema with name 'users' 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:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.nifi.schema.access.SchemaNotFoundException: java.io.IOException: Failed to retrieve schema with name 'users' 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.GeneratedMethodAccessor616.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.$Proxy248.createRecordReader(Unknown Source) at org.apache.nifi.processors.standard.AbstractRecordProcessor$1.process(AbstractRecordProcessor.java:113) ... 14 common frames omitted Caused by: java.io.IOException: Failed to retrieve schema with name 'users' at org.apache.nifi.schemaregistry.hortonworks.HortonworksSchemaRegistry.handleException(HortonworksSchemaRegistry.java:332) at org.apache.nifi.schemaregistry.hortonworks.HortonworksSchemaRegistry.retrieveSchema(HortonworksSchemaRegistry.java:252) at sun.reflect.GeneratedMethodAccessor617.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.$Proxy251.retrieveSchema(Unknown Source) at org.apache.nifi.schema.access.SchemaNamePropertyStrategy.getSchema(SchemaNamePropertyStrategy.java:53) ... 22 common frames omitted Caused by: java.lang.RuntimeException: com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException: Unrecognized field "schemaMetadataId" (class com.hortonworks.registries.schemaregistry.SchemaVersionInfo), not marked as ignorable (6 known properties: "timestamp", "version", "id", "description", "schemaText", "name"]) at [Source: (String)"{"id":1,"schemaMetadataId":1,"name":"users","description":"Schema for user.csv","version":1,"schemaText":"{\n\"type\": \"record\",\n\"name\": \"UserRecord\",\n\"fields\" : [\n\t{\"name\": \"id\", \"type\": \"long\"},\n\t{\"name\": \"title\", \"type\": [\"null\", \"string\"]},\n\t{\"name\": \"first\", \"type\": [\"null\", \"string\"]},\n\t{\"name\": \"last\", \"type\": [\"null\", \"string\"]},\n\t{\"name\": \"street\", \"type\": [\"null\", \"string\"]},\n\t{\"name\": \"city\", \"type\": [\"null\""[truncated 1065 chars]; line: 1, column: 29] (through reference chain: com.hortonworks.registries.schemaregistry.SchemaVersionInfo["schemaMetadataId"]) at com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient.readEntity(SchemaRegistryClient.java:748) at com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient.getEntity(SchemaRegistryClient.java:760) at com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient.getLatestSchemaVersionInfo(SchemaRegistryClient.java:539) at org.apache.nifi.schemaregistry.hortonworks.HortonworksSchemaRegistry.getLatestSchemaVersionInfo(HortonworksSchemaRegistry.java:172) at org.apache.nifi.schemaregistry.hortonworks.HortonworksSchemaRegistry.retrieveSchema(HortonworksSchemaRegistry.java:246) ... 28 common frames omitted Caused by: com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException: Unrecognized field "schemaMetadataId" (class com.hortonworks.registries.schemaregistry.SchemaVersionInfo), not marked as ignorable (6 known properties: "timestamp", "version", "id", "description", "schemaText", "name"]) at [Source: (String)"{"id":1,"schemaMetadataId":1,"name":"users","description":"Schema for user.csv","version":1,"schemaText":"{\n\"type\": \"record\",\n\"name\": \"UserRecord\",\n\"fields\" : [\n\t{\"name\": \"id\", \"type\": \"long\"},\n\t{\"name\": \"title\", \"type\": [\"null\", \"string\"]},\n\t{\"name\": \"first\", \"type\": [\"null\", \"string\"]},\n\t{\"name\": \"last\", \"type\": [\"null\", \"string\"]},\n\t{\"name\": \"street\", \"type\": [\"null\", \"string\"]},\n\t{\"name\": \"city\", \"type\": [\"null\""[truncated 1065 chars]; line: 1, column: 29] (through reference chain: com.hortonworks.registries.schemaregistry.SchemaVersionInfo["schemaMetadataId"]) at com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException.from(UnrecognizedPropertyException.java:60) at com.fasterxml.jackson.databind.DeserializationContext.handleUnknownProperty(DeserializationContext.java:822) at com.fasterxml.jackson.databind.deser.std.StdDeserializer.handleUnknownProperty(StdDeserializer.java:1151) at com.fasterxml.jackson.databind.deser.BeanDeserializerBase.handleUnknownProperty(BeanDeserializerBase.java:1567) at com.fasterxml.jackson.databind.deser.BeanDeserializerBase.handleUnknownVanilla(BeanDeserializerBase.java:1545) at com.fasterxml.jackson.databind.deser.BeanDeserializer.vanillaDeserialize(BeanDeserializer.java:293) at com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize(BeanDeserializer.java:151) at com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4001) at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:2992) at com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient.readEntity(SchemaRegistryClient.java:746) ... 32 common frames omitted 2018-05-23 10:47:52,639 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@3d7a8279 // Another save pending = false