Hello community, I'm starting my first steps with NiFi, and enjoining how it works!
I started with version 0.4.1 and a simple flow: ExecuteSQL -> ConvertAvroToJSON -> PutEventHub Reading from an Oracle database, and everything works like a charm! Few days ago NiFi 0.5.1 has been released, and I tried a rolling upgrade, using my old NiFi flow. The update goes right and my flow is loaded correctly. The problem is when I starts the ExecuteSQL processor, it doesn't works... In log file I can see this trace: ERROR [Timer-Driven Process Thread-8] o.a.nifi.processors.standard.ExecuteSQL org.apache.avro.SchemaParseException: Empty name at org.apache.avro.Schema.validateName(Schema.java:1076) ~[na:na] at org.apache.avro.Schema.access$200(Schema.java:79) ~[na:na] at org.apache.avro.Schema$Name.<init>(Schema.java:436) ~[na:na] at org.apache.avro.Schema.createRecord(Schema.java:145) ~[na:na] at org.apache.avro.SchemaBuilder$RecordBuilder.fields(SchemaBuilder.java:1732) ~[na:na] at org.apache.nifi.processors.standard.util.JdbcCommon.createSchema(JdbcCommon.java:138) ~[na:na] at org.apache.nifi.processors.standard.util.JdbcCommon.convertToAvroStream(JdbcCommon.java:72) ~[na:na] at org.apache.nifi.processors.standard.ExecuteSQL$1.process(ExecuteSQL.java:158) ~[na:na] at org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:1953) ~[nifi-framework-core-0.5.1.jar:0.5.1] at org.apache.nifi.processors.standard.ExecuteSQL.onTrigger(ExecuteSQL.java:152) ~[na:na] at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) ~[nifi-api-0.5.1.jar:0.5.1] at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1139) [nifi-framework-core-0.5.1.jar:0.5.1] at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:139) [nifi-framework-core-0.5.1.jar:0.5.1] at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:49) [nifi-framework-core-0.5.1.jar:0.5.1] at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:124) [nifi-framework-core-0.5.1.jar:0.5.1] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) [na:1.7.0_79] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304) [na:1.7.0_79] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) [na:1.7.0_79] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [na:1.7.0_79] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [na:1.7.0_79] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_79] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79] I tried with a clean installation of NiFi 0.5.1 and new clean flow, but the error stills appears, and the processor doesn't starts. With a downgrade to NiFi 0.4.1 the processor works perfectly. Do you have any idea of what can be failing? Do you think I'm doing something wrong? Thanks in advance! Marcelo -- ................................................................... Marcelo Valle Ávila mva...@keedio.com |+34 630 371 156 www.keedio.com ...................................................................
