Hi Aaron, Attached is a simple flow that publishes events to an eventhub I have -- if you want to try and publish to it, hit me up privately and I can share the info for the hub.
Thanks, Andrew On Thu, Aug 11, 2016 at 9:11 AM, Andrew Psaltis <psaltis.and...@gmail.com> wrote: > Hey Aaron, > Sorry for the slow response, I have been traveling and was not able to get > quality time with the keyboard. Ironically I was just starting up my nifi > 0.7 when I saw this email come through. > > Let me see if I can repo the problem going to one of my eventhubs > > On Thu, Aug 11, 2016 at 9:04 AM, Smith, Aaron <asm...@hpe.com> wrote: > >> Hey Andrew, >> >> >> >> I just wanted to check and see if you were able to come up with anything >> else for me on this matter? >> >> >> >> Thanks, >> >> >> >> >> *Aaron Smith *Global Solutions Engineer >> EG WW HQ Presales >> >> >> asm...@hpe.com >> T +1 832 502 8829 >> >> Houston, Texas USA >> >> [image: >> http://graphics8.nytimes.com/images/2015/06/03/technology/03bits-hp/03bits-hp-master315.png] >> >> >> >> *From:* Andrew Psaltis [mailto:psaltis.and...@gmail.com] >> *Sent:* Tuesday, August 9, 2016 12:46 PM >> >> *To:* users@nifi.apache.org >> *Subject:* Re: putazureeventhub error >> >> >> >> Aaron, >> >> Sorry about that -- the notion of using the IP address was certainly an >> error between my seat and keyboard. I will try and get things going with >> the 0.7.0 release and see if I can reproduce the error. >> >> >> >> >> >> Thanks, >> >> Andrew >> >> >> >> On Tue, Aug 9, 2016 at 12:04 PM, Smith, Aaron <asm...@hpe.com> wrote: >> >> I have not, where would I actually put that IP? From my understanding of >> the processor, its stringing together the information I gave it for the >> location of the event hub, to get the URL that its sending information to. >> >> >> >> Thanks, >> >> >> >> >> *Aaron Smith *Global Solutions Engineer >> EG WW HQ Presales >> >> >> asm...@hpe.com >> T +1 832 502 8829 >> >> Houston, Texas USA >> >> [image: >> http://graphics8.nytimes.com/images/2015/06/03/technology/03bits-hp/03bits-hp-master315.png] >> >> >> >> *From:* Andrew Psaltis [mailto:psaltis.and...@gmail.com] >> *Sent:* Tuesday, August 9, 2016 10:54 AM >> >> >> *To:* users@nifi.apache.org >> *Subject:* Re: putazureeventhub error >> >> >> >> Aaron, >> >> It seems like that may be coming from this line: https://github.com/apach >> e/nifi/blob/rel/nifi-0.7.0/nifi-nar-bundles/nifi-azure-bu >> ndle/nifi-azure-processors/src/main/java/org/apache/nifi/pro >> cessors/azure/eventhub/PutAzureEventHub.java#L137 >> >> >> >> Have tried using the public IP address? >> >> >> >> FYI -- the 0.7.0 code uses an old Azure client and in 1.0.0 the new and >> recommended client is used. Not that I am indicating this one won't work, >> just point it out. I need to step away, but can try and looking into it >> closer when I return. >> >> >> >> Thanks, >> >> Andrew >> >> >> >> On Tue, Aug 9, 2016 at 11:34 AM, Smith, Aaron <asm...@hpe.com> wrote: >> >> Hi Andrew, >> >> >> >> I was able to resolve it from the machine NiFi is running on, by adding >> the name server. Now my error looks like: >> >> >> >> >> >> >> >> 2016-08-09 10:29:26,981 ERROR [StandardProcessScheduler Thread-1] >> o.a.n.p.azure.eventhub.PutAzureEventHub >> PutAzureEventHub[id=e6a62157-b3f8-4de0-921f-0a5e1b7678d6] >> PutAzureEventHub[id=e6a62157-b3f8-4de0-921f-0a5e1b7678d6] failed to >> invoke @OnScheduled method due to java.lang.RuntimeException: Timed out >> while executing one of processor's OnScheduled task.; processor will not be >> scheduled to run for 30000 milliseconds: java.lang.RuntimeException: Timed >> out while executing one of processor's OnScheduled task. >> >> 2016-08-09 10:29:26,982 ERROR [StandardProcessScheduler Thread-1] >> o.a.n.p.azure.eventhub.PutAzureEventHub >> >> java.lang.RuntimeException: Timed out while executing one of processor's >> OnScheduled task. >> >> at org.apache.nifi.controller.StandardProcessorNode.invokeTaskA >> sCancelableFuture(StandardProcessorNode.java:1390) ~[na:na] >> >> at >> org.apache.nifi.controller.StandardProcessorNode.access$100(StandardProcessorNode.java:90) >> ~[na:na] >> >> at >> org.apache.nifi.controller.StandardProcessorNode$1.run(StandardProcessorNode.java:1230) >> ~[na:na] >> >> at >> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) >> [na:1.8.0_91] >> >> at java.util.concurrent.FutureTask.run(FutureTask.java:266) >> [na:1.8.0_91] >> >> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu >> tureTask.access$201(ScheduledThreadPoolExecutor.java:180) [na:1.8.0_91] >> >> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu >> tureTask.run(ScheduledThreadPoolExecutor.java:293) [na:1.8.0_91] >> >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) >> [na:1.8.0_91] >> >> 8.0_91] >> >> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu >> tureTask.access$201(ScheduledThreadPoolExecutor.java:180) [na:1.8.0_91] >> >> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu >> tureTask.run(ScheduledThreadPoolExecutor.java:293) [na:1.8.0_91] >> >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) >> [na:1.8.0_91] >> >> at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) >> [na:1.8.0_91] >> >> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91] >> >> Caused by: java.util.concurrent.TimeoutException: null >> >> at java.util.concurrent.FutureTask.get(FutureTask.java:205) >> [na:1.8.0_91] >> >> at org.apache.nifi.controller.StandardProcessorNode.invokeTaskA >> sCancelableFuture(StandardProcessorNode.java:1375) ~[na:na] >> >> ... 9 common frames omitted >> >> 2016-08-09 10:29:26,983 ERROR [StandardProcessScheduler Thread-1] >> o.a.n.controller.StandardProcessorNode Failed to invoke @OnScheduled >> method due to java.lang.RuntimeException: Timed out while executing one of >> processor's OnScheduled task. >> >> java.lang.RuntimeException: Timed out while executing one of processor's >> OnScheduled task. >> >> at org.apache.nifi.controller.StandardProcessorNode.invokeTaskA >> sCancelableFuture(StandardProcessorNode.java:1390) ~[na:na] >> >> at >> org.apache.nifi.controller.StandardProcessorNode.access$100(StandardProcessorNode.java:90) >> ~[na:na] >> >> >> >> *From:* Oxenberg, Jeff >> *Sent:* Tuesday, August 09, 2016 10:27 AM >> *To:* Smith, Aaron <asm...@hpe.com> >> *Subject:* >> >> >> >> 2016-08-09 10:00:10,143 ERROR [StandardProcessScheduler Thread-7] >> o.a.n.p.azure.eventhub.PutAzureEventHub >> PutAzureEventHub[id=e6a62157-b3f8-4de0-921f-0a5e1b7678d6] >> PutAzureEventHub[id=e6a62157-b3f8-4de0-921f-0a5e1b7678d6] failed to >> invoke @OnScheduled method due to java.lang.RuntimeException: Failed while >> executing one of processor's OnScheduled task.; processor will not be >> scheduled to run for 30000 milliseconds: java.lang.RuntimeException: Failed >> while executing one of processor's OnScheduled task. >> >> 2016-08-09 10:00:10,147 ERROR [StandardProcessScheduler Thread-3] >> org.apache.nifi.engine.FlowEngine A flow controller task execution >> stopped abnormally >> >> java.util.concurrent.ExecutionException: java.lang.reflect.InvocationTa >> rgetException >> >> at java.util.concurrent.FutureTask.report(FutureTask.java:122) >> ~[na:1.8.0_91] >> >> at java.util.concurrent.FutureTask.get(FutureTask.java:192) >> ~[na:1.8.0_91] >> >> at >> org.apache.nifi.engine.FlowEngine.afterExecute(FlowEngine.java:100) >> ~[na:na] >> >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1150) >> [na:1.8.0_91] >> >> at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) >> [na:1.8.0_91] >> >> at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) >> [na:1.8.0_91] >> >> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91] >> >> Caused by: java.lang.reflect.InvocationTargetException: null >> >> at sun.reflect.GeneratedMethodAccessor404.invoke(Unknown Source) >> ~[na:na] >> >> at >> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) >> ~[na:1.8.0_91] >> >> at java.lang.reflect.Method.invoke(Method.java:498) >> ~[na:1.8.0_91] >> >> at org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnota >> tions(ReflectionUtils.java:137) ~[na:na] >> >> at org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnota >> tions(ReflectionUtils.java:125) ~[na:na] >> >> at >> org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:70) >> ~[na:na] >> >> at org.apache.nifi.controller.StandardProcessorNode$1$1.call( >> StandardProcessorNode.java:1234) ~[na:na] >> >> at org.apache.nifi.controller.StandardProcessorNode$1$1.call( >> StandardProcessorNode.java:1230) ~[na:na] >> >> at java.util.concurrent.FutureTask.run(FutureTask.java:266) >> ~[na:1.8.0_91] >> >> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu >> tureTask.access$201(ScheduledThreadPoolExecutor.java:180) ~[na:1.8.0_91] >> >> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu >> tureTask.run(ScheduledThreadPoolExecutor.java:293) ~[na:1.8.0_91] >> >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) >> [na:1.8.0_91] >> >> ... 2 common frames omitted >> >> Caused by: com.microsoft.eventhubs.client.EventHubException: >> org.apache.qpid.amqp_1_0.client.ConnectionException: >> java.net.UnknownHostException: iot-cloud-ns.servicebus.windows.net >> >> at >> com.microsoft.eventhubs.client.EventHubClient.createConnection(EventHubClient.java:99) >> ~[na:na] >> >> at >> com.microsoft.eventhubs.client.EventHubClient.<init>(EventHubClient.java:36) >> ~[na:na] >> >> at >> com.microsoft.eventhubs.client.EventHubClient.create(EventHubClient.java:60) >> ~[na:na] >> >> at org.apache.nifi.processors.azure.eventhub.PutAzureEventHub. >> setupClient(PutAzureEventHub.java:137) ~[na:na] >> >> ... 14 common frames omitted >> >> Caused by: org.apache.qpid.amqp_1_0.client.ConnectionException: >> java.net.UnknownHostException: iot-cloud-ns.servicebus.windows.net >> >> at org.apache.qpid.amqp_1_0.client.TCPTransportProvider.connect >> (TCPTransportProvider.java:203) ~[na:na] >> >> at >> org.apache.qpid.amqp_1_0.client.Connection.<init>(Connection.java:278) >> ~[na:na] >> >> at >> org.apache.qpid.amqp_1_0.client.Connection.<init>(Connection.java:182) >> ~[na:na] >> >> at >> org.apache.qpid.amqp_1_0.client.Connection.<init>(Connection.java:125) >> ~[na:na] >> >> at >> com.microsoft.eventhubs.client.EventHubClient.createConnection(EventHubClient.java:91) >> ~[na:na] >> >> ... 17 common frames omitted >> >> Caused by: java.net.UnknownHostException: iot-cloud-ns.servicebus.window >> s.net >> >> at >> java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:184) >> ~[na:1.8.0_91] >> >> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) >> ~[na:1.8.0_91] >> >> at java.net.Socket.connect(Socket.java:589) ~[na:1.8.0_91] >> >> at sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:668) >> ~[na:1.8.0_91] >> >> at sun.security.ssl.SSLSocketImpl.<init>(SSLSocketImpl.java:427) >> ~[na:1.8.0_91] >> >> at >> sun.security.ssl.SSLSocketFactoryImpl.createSocket(SSLSocketFactoryImpl.java:88) >> ~[na:1.8.0_91] >> >> at >> org.apache.qpid.amqp_1_0.client.TCPTransportProvider.connect(TCPTransportProvider.java:81) >> ~[na:na] >> >> ... 21 common frames omitted >> >> 2016-08-09 10:00:10,147 ERROR [StandardProcessScheduler Thread-7] >> o.a.n.p.azure.eventhub.PutAzureEventHub >> >> java.lang.RuntimeException: Failed while executing one of processor's >> OnScheduled task. >> >> at org.apache.nifi.controller.StandardProcessorNode.invokeTaskA >> sCancelableFuture(StandardProcessorNode.java:1392) ~[na:na] >> >> at >> org.apache.nifi.controller.StandardProcessorNode.access$100(StandardProcessorNode.java:90) >> ~[na:na] >> >> at >> org.apache.nifi.controller.StandardProcessorNode$1.run(StandardProcessorNode.java:1230) >> ~[na:na] >> >> at >> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) >> [na:1.8.0_91] >> >> >> >> nslookup iot-cloud-ns.servicebus.windows.net >> >> Server: 10.82.0.1 >> >> Address: 10.82.0.1#53 >> >> >> >> Non-authoritative answer: >> >> iot-cloud-ns.servicebus.windows.net canonical name = >> ns-sb2-prod-dm2-011.cloudapp.net. >> >> Name: ns-sb2-prod-dm2-011.cloudapp.net >> >> Address: 40.86.102.100 >> >> >> >> >> >> >> >> Thanks, >> >> >> >> >> *Aaron Smith *Global Solutions Engineer >> EG WW HQ Presales >> >> >> asm...@hpe.com >> T +1 832 502 8829 >> >> Houston, Texas USA >> >> [image: >> http://graphics8.nytimes.com/images/2015/06/03/technology/03bits-hp/03bits-hp-master315.png] >> >> >> >> *From:* Andrew Psaltis [mailto:psaltis.and...@gmail.com] >> *Sent:* Tuesday, August 9, 2016 10:30 AM >> >> >> *To:* users@nifi.apache.org >> *Subject:* Re: putazureeventhub error >> >> >> >> Aaron, >> >> It looks like the source of the error is this line: >> >> >> >> "org.apache.qpid.amqp_1_0.client.ConnectionException: >> java.net.UnknownHostException: iot-cloud-ns.servicebus.windows.net" >> >> >> >> Are you able to resolve that DNS name from the machine you are running >> NiFi on? If not you can also try the public IP address. >> >> >> >> Thanks, >> >> Andrew >> >> >> >> On Tue, Aug 9, 2016 at 11:27 AM, Smith, Aaron <asm...@hpe.com> wrote: >> >> Hi Mark, >> >> >> >> Here is what was in the log: >> >> >> >> 2016-08-09 10:00:10,143 ERROR [StandardProcessScheduler Thread-7] >> o.a.n.p.azure.eventhub.PutAzureEventHub >> PutAzureEventHub[id=e6a62157-b3f8-4de0-921f-0a5e1b7678d6] >> PutAzureEventHub[id=e6a62157-b3f8-4de0-921f-0a5e1b7678d6] failed to >> invoke @OnScheduled method due to java.lang.RuntimeException: Failed while >> executing one of processor's OnScheduled task.; processor will not be >> scheduled to run for 30000 milliseconds: java.lang.RuntimeException: Failed >> while executing one of processor's OnScheduled task. >> >> 2016-08-09 10:00:10,147 ERROR [StandardProcessScheduler Thread-3] >> org.apache.nifi.engine.FlowEngine A flow controller task execution >> stopped abnormally >> >> java.util.concurrent.ExecutionException: java.lang.reflect.InvocationTa >> rgetException >> >> at java.util.concurrent.FutureTask.report(FutureTask.java:122) >> ~[na:1.8.0_91] >> >> at java.util.concurrent.FutureTask.get(FutureTask.java:192) >> ~[na:1.8.0_91] >> >> at >> org.apache.nifi.engine.FlowEngine.afterExecute(FlowEngine.java:100) >> ~[na:na] >> >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1150) >> [na:1.8.0_91] >> >> at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) >> [na:1.8.0_91] >> >> at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) >> [na:1.8.0_91] >> >> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91] >> >> Caused by: java.lang.reflect.InvocationTargetException: null >> >> at sun.reflect.GeneratedMethodAccessor404.invoke(Unknown Source) >> ~[na:na] >> >> at >> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) >> ~[na:1.8.0_91] >> >> at java.lang.reflect.Method.invoke(Method.java:498) >> ~[na:1.8.0_91] >> >> at org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnota >> tions(ReflectionUtils.java:137) ~[na:na] >> >> at org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnota >> tions(ReflectionUtils.java:125) ~[na:na] >> >> at >> org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:70) >> ~[na:na] >> >> at org.apache.nifi.controller.StandardProcessorNode$1$1.call( >> StandardProcessorNode.java:1234) ~[na:na] >> >> at org.apache.nifi.controller.StandardProcessorNode$1$1.call( >> StandardProcessorNode.java:1230) ~[na:na] >> >> at java.util.concurrent.FutureTask.run(FutureTask.java:266) >> ~[na:1.8.0_91] >> >> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu >> tureTask.access$201(ScheduledThreadPoolExecutor.java:180) ~[na:1.8.0_91] >> >> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu >> tureTask.run(ScheduledThreadPoolExecutor.java:293) ~[na:1.8.0_91] >> >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) >> [na:1.8.0_91] >> >> ... 2 common frames omitted >> >> Caused by: com.microsoft.eventhubs.client.EventHubException: >> org.apache.qpid.amqp_1_0.client.ConnectionException: >> java.net.UnknownHostException: iot-cloud-ns.servicebus.windows.net >> >> at >> com.microsoft.eventhubs.client.EventHubClient.createConnection(EventHubClient.java:99) >> ~[na:na] >> >> at >> com.microsoft.eventhubs.client.EventHubClient.<init>(EventHubClient.java:36) >> ~[na:na] >> >> at >> com.microsoft.eventhubs.client.EventHubClient.create(EventHubClient.java:60) >> ~[na:na] >> >> at org.apache.nifi.processors.azure.eventhub.PutAzureEventHub. >> setupClient(PutAzureEventHub.java:137) ~[na:na] >> >> ... 14 common frames omitted >> >> Caused by: org.apache.qpid.amqp_1_0.client.ConnectionException: >> java.net.UnknownHostException: iot-cloud-ns.servicebus.windows.net >> >> at org.apache.qpid.amqp_1_0.client.TCPTransportProvider.connect >> (TCPTransportProvider.java:203) ~[na:na] >> >> at >> org.apache.qpid.amqp_1_0.client.Connection.<init>(Connection.java:278) >> ~[na:na] >> >> at >> org.apache.qpid.amqp_1_0.client.Connection.<init>(Connection.java:182) >> ~[na:na] >> >> at >> org.apache.qpid.amqp_1_0.client.Connection.<init>(Connection.java:125) >> ~[na:na] >> >> at >> com.microsoft.eventhubs.client.EventHubClient.createConnection(EventHubClient.java:91) >> ~[na:na] >> >> ... 17 common frames omitted >> >> Caused by: java.net.UnknownHostException: iot-cloud-ns.servicebus.window >> s.net >> >> at >> java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:184) >> ~[na:1.8.0_91] >> >> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) >> ~[na:1.8.0_91] >> >> at java.net.Socket.connect(Socket.java:589) ~[na:1.8.0_91] >> >> at sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:668) >> ~[na:1.8.0_91] >> >> at sun.security.ssl.SSLSocketImpl.<init>(SSLSocketImpl.java:427) >> ~[na:1.8.0_91] >> >> at >> sun.security.ssl.SSLSocketFactoryImpl.createSocket(SSLSocketFactoryImpl.java:88) >> ~[na:1.8.0_91] >> >> at >> org.apache.qpid.amqp_1_0.client.TCPTransportProvider.connect(TCPTransportProvider.java:81) >> ~[na:na] >> >> ... 21 common frames omitted >> >> 2016-08-09 10:00:10,147 ERROR [StandardProcessScheduler Thread-7] >> o.a.n.p.azure.eventhub.PutAzureEventHub >> >> java.lang.RuntimeException: Failed while executing one of processor's >> OnScheduled task. >> >> at org.apache.nifi.controller.StandardProcessorNode.invokeTaskA >> sCancelableFuture(StandardProcessorNode.java:1392) ~[na:na] >> >> at >> org.apache.nifi.controller.StandardProcessorNode.access$100(StandardProcessorNode.java:90) >> ~[na:na] >> >> at >> org.apache.nifi.controller.StandardProcessorNode$1.run(StandardProcessorNode.java:1230) >> ~[na:na] >> >> at >> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) >> [na:1.8.0_91] >> >> >> >> nslookup iot-cloud-ns.servicebus.windows.net >> >> Server: 10.82.0.1 >> >> Address: 10.82.0.1#53 >> >> >> >> Non-authoritative answer: >> >> iot-cloud-ns.servicebus.windows.net canonical name = >> ns-sb2-prod-dm2-011.cloudapp.net. >> >> Name: ns-sb2-prod-dm2-011.cloudapp.net >> >> Address: 40.86.102.100 >> >> >> >> >> >> >> >> Thanks, >> >> >> >> >> *Aaron Smith *Global Solutions Engineer >> EG WW HQ Presales >> >> >> asm...@hpe.com >> T +1 832 502 8829 >> >> Houston, Texas USA >> >> [image: >> http://graphics8.nytimes.com/images/2015/06/03/technology/03bits-hp/03bits-hp-master315.png] >> >> >> >> *From:* Mark Payne [mailto:marka...@hotmail.com] >> *Sent:* Tuesday, August 9, 2016 10:05 AM >> *To:* users@nifi.apache.org >> *Subject:* Re: putazureeventhub error >> >> >> >> Hi Aaron, >> >> >> >> Can you check the logs to see if there is any more information? >> >> >> >> Thanks >> >> -Mark >> >> >> >> On Aug 9, 2016, at 10:58 AM, Smith, Aaron <asm...@hpe.com> wrote: >> >> >> >> I am trying to use the put azure event hub processor in nifi .7 and am >> getting the below error: >> >> >> >> PutAzureEventHub[id=e6a62157-b3f8-4de0-921f-0a5e1b7678d6] >> PutAzureEventHub[id=e6a62157-b3f8-4de0-921f-0a5e1b7678d6] failed to >> invoke @OnScheduled method due to java.lang.RuntimeException: Failed while >> executing one of processor's OnScheduled task.; processor will not be >> scheduled to run for 30000 milliseconds: java.lang.RuntimeException: Failed >> while executing one of processor's OnScheduled task. >> >> >> >> Please let me know if anyone has encountered this error and how you fixed >> it. >> >> >> >> >> >> Thanks, >> >> >> >> >> *Aaron Smith *Global Solutions Engineer >> EG WW HQ Presales >> >> >> asm...@hpe.com >> T +1 832 502 8829 >> >> Houston, Texas USA >> >> <image001.png> >> >> >> >> >> >> >> >> -- >> >> Thanks, >> >> Andrew >> >> >> >> Subscribe to my book: Streaming Data <http://manning.com/psaltis> >> >> twiiter: @itmdata <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> >> >> >> >> <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> >> >> <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> >> >> -- <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> >> >> Thanks, <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> >> >> Andrew <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> >> >> <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> >> >> Subscribe to my book: Streaming Data >> <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> >> >> <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> >> >> twiiter: @itmdata <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> >> >> >> >> >> >> -- >> >> Thanks, >> >> Andrew >> >> >> >> Subscribe to my book: Streaming Data <http://manning.com/psaltis> >> >> <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> >> >> twiiter: @itmdata <http://twitter.com/intent/user?screen_name=itmdata> >> > > > > -- > Thanks, > Andrew > > Subscribe to my book: Streaming Data <http://manning.com/psaltis> > <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> > twiiter: @itmdata <http://twitter.com/intent/user?screen_name=itmdata> > -- Thanks, Andrew Subscribe to my book: Streaming Data <http://manning.com/psaltis> <https://www.linkedin.com/pub/andrew-psaltis/1/17b/306> twiiter: @itmdata <http://twitter.com/intent/user?screen_name=itmdata>
<?xml version="1.0" encoding="UTF-8" standalone="yes"?><template><description>This flow just puts random data into an event hub</description><name>PutAzureEventHub-SimpleTest</name><snippet><connections><id>a4d87c72-1e7a-49f7-b30e-0f97dc20c1b4</id><parentGroupId>4caac796-d027-4e1b-b1d4-0c7657545225</parentGroupId><backPressureDataSizeThreshold>0 MB</backPressureDataSizeThreshold><backPressureObjectThreshold>0</backPressureObjectThreshold><destination><groupId>4caac796-d027-4e1b-b1d4-0c7657545225</groupId><id>4d6fe16b-b252-48de-b3ea-f04612eab70d</id><type>PROCESSOR</type></destination><flowFileExpiration>0 sec</flowFileExpiration><labelIndex>1</labelIndex><name></name><selectedRelationships>success</selectedRelationships><source><groupId>4caac796-d027-4e1b-b1d4-0c7657545225</groupId><id>6fdd6e8d-b298-4f5c-9bcd-2d555c460186</id><type>PROCESSOR</type></source><zIndex>0</zIndex></connections><connections><id>a44bca29-6ebf-478f-83b1-d9d0bc6e82cd</id><parentGroupId>4caac796-d027-4e1b-b1d4-0c7657545225</parentGroupId><backPressureDataSizeThreshold>0 MB</backPressureDataSizeThreshold><backPressureObjectThreshold>0</backPressureObjectThreshold><destination><groupId>4caac796-d027-4e1b-b1d4-0c7657545225</groupId><id>3619de4c-4748-4fe9-846f-0690f06bfb22</id><type>PROCESSOR</type></destination><flowFileExpiration>0 sec</flowFileExpiration><labelIndex>1</labelIndex><name></name><selectedRelationships>success</selectedRelationships><source><groupId>4caac796-d027-4e1b-b1d4-0c7657545225</groupId><id>4d6fe16b-b252-48de-b3ea-f04612eab70d</id><type>PROCESSOR</type></source><zIndex>0</zIndex></connections><connections><id>ff809156-620f-4be0-8964-07ea609c3073</id><parentGroupId>4caac796-d027-4e1b-b1d4-0c7657545225</parentGroupId><backPressureDataSizeThreshold>0 MB</backPressureDataSizeThreshold><backPressureObjectThreshold>0</backPressureObjectThreshold><bends><x>830.0</x><y>46.0</y></bends><bends><x>830.0</x><y>96.0</y></bends><destination><groupId>4caac796-d027-4e1b-b1d4-0c7657545225</groupId><id>4d6fe16b-b252-48de-b3ea-f04612eab70d</id><type>PROCESSOR</type></destination><flowFileExpiration>0 sec</flowFileExpiration><labelIndex>1</labelIndex><name></name><selectedRelationships>failure</selectedRelationships><source><groupId>4caac796-d027-4e1b-b1d4-0c7657545225</groupId><id>4d6fe16b-b252-48de-b3ea-f04612eab70d</id><type>PROCESSOR</type></source><zIndex>0</zIndex></connections><processors><id>6fdd6e8d-b298-4f5c-9bcd-2d555c460186</id><parentGroupId>4caac796-d027-4e1b-b1d4-0c7657545225</parentGroupId><position><x>-17.0</x><y>5.0</y></position><config><bulletinLevel>WARN</bulletinLevel><comments></comments><concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount><defaultConcurrentTasks><entry><key>TIMER_DRIVEN</key><value>1</value></entry><entry><key>EVENT_DRIVEN</key><value>0</value></entry><entry><key>CRON_DRIVEN</key><value>1</value></entry></defaultConcurrentTasks><defaultSchedulingPeriod><entry><key>TIMER_DRIVEN</key><value>0 sec</value></entry><entry><key>CRON_DRIVEN</key><value>* * * * * ?</value></entry></defaultSchedulingPeriod><descriptors><entry><key>File Size</key><value><description>The size of the file that will be used</description><displayName>File Size</displayName><dynamic>false</dynamic><name>File Size</name><required>true</required><sensitive>false</sensitive><supportsEl>false</supportsEl></value></entry><entry><key>Batch Size</key><value><defaultValue>1</defaultValue><description>The number of FlowFiles to be transferred in each invocation</description><displayName>Batch Size</displayName><dynamic>false</dynamic><name>Batch Size</name><required>true</required><sensitive>false</sensitive><supportsEl>false</supportsEl></value></entry><entry><key>Data Format</key><value><allowableValues><displayName>Binary</displayName><value>Binary</value></allowableValues><allowableValues><displayName>Text</displayName><value>Text</value></allowableValues><defaultValue>Binary</defaultValue><description>Specifies whether the data should be Text or Binary</description><displayName>Data Format</displayName><dynamic>false</dynamic><name>Data Format</name><required>true</required><sensitive>false</sensitive><supportsEl>false</supportsEl></value></entry><entry><key>Unique FlowFiles</key><value><allowableValues><displayName>true</displayName><value>true</value></allowableValues><allowableValues><displayName>false</displayName><value>false</value></allowableValues><defaultValue>false</defaultValue><description>If true, each FlowFile that is generated will be unique. If false, a random value will be generated and all FlowFiles will get the same content but this offers much higher throughput</description><displayName>Unique FlowFiles</displayName><dynamic>false</dynamic><name>Unique FlowFiles</name><required>true</required><sensitive>false</sensitive><supportsEl>false</supportsEl></value></entry></descriptors><lossTolerant>false</lossTolerant><penaltyDuration>30 sec</penaltyDuration><properties><entry><key>File Size</key><value>10 B</value></entry><entry><key>Batch Size</key></entry><entry><key>Data Format</key><value>Text</value></entry><entry><key>Unique FlowFiles</key></entry></properties><runDurationMillis>0</runDurationMillis><schedulingPeriod>0 sec</schedulingPeriod><schedulingStrategy>TIMER_DRIVEN</schedulingStrategy><yieldDuration>1 sec</yieldDuration></config><name>GenerateFlowFile</name><relationships><autoTerminate>false</autoTerminate><description></description><name>success</name></relationships><state>STOPPED</state><style/><supportsEventDriven>false</supportsEventDriven><supportsParallelProcessing>true</supportsParallelProcessing><type>org.apache.nifi.processors.standard.GenerateFlowFile</type></processors><processors><id>4d6fe16b-b252-48de-b3ea-f04612eab70d</id><parentGroupId>4caac796-d027-4e1b-b1d4-0c7657545225</parentGroupId><position><x>421.0</x><y>21.0</y></position><config><bulletinLevel>WARN</bulletinLevel><comments></comments><concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount><defaultConcurrentTasks><entry><key>TIMER_DRIVEN</key><value>1</value></entry><entry><key>EVENT_DRIVEN</key><value>0</value></entry><entry><key>CRON_DRIVEN</key><value>1</value></entry></defaultConcurrentTasks><defaultSchedulingPeriod><entry><key>TIMER_DRIVEN</key><value>0 sec</value></entry><entry><key>CRON_DRIVEN</key><value>* * * * * ?</value></entry></defaultSchedulingPeriod><descriptors><entry><key>Event Hub Name</key><value><description>The name of the Azure Event Hub to send to</description><displayName>Event Hub Name</displayName><dynamic>false</dynamic><name>Event Hub Name</name><required>true</required><sensitive>false</sensitive><supportsEl>false</supportsEl></value></entry><entry><key>Event Hub Namespace</key><value><description>The Azure Namespace that the Event Hub is assigned to. This is generally equal to <Event Hub Name>-ns</description><displayName>Event Hub Namespace</displayName><dynamic>false</dynamic><name>Event Hub Namespace</name><required>true</required><sensitive>false</sensitive><supportsEl>false</supportsEl></value></entry><entry><key>Shared Access Policy Name</key><value><description>The name of the Event Hub Shared Access Policy. This Policy must have Send permissions.</description><displayName>Shared Access Policy Name</displayName><dynamic>false</dynamic><name>Shared Access Policy Name</name><required>true</required><sensitive>false</sensitive><supportsEl>false</supportsEl></value></entry><entry><key>Shared Access Policy Primary Key</key><value><description>The primary key of the Event Hub Shared Access Policy</description><displayName>Shared Access Policy Primary Key</displayName><dynamic>false</dynamic><name>Shared Access Policy Primary Key</name><required>true</required><sensitive>true</sensitive><supportsEl>false</supportsEl></value></entry></descriptors><lossTolerant>false</lossTolerant><penaltyDuration>30 sec</penaltyDuration><properties><entry><key>Event Hub Name</key><value>nifi-test</value></entry><entry><key>Event Hub Namespace</key><value>apsaltis-test</value></entry><entry><key>Shared Access Policy Name</key><value>agp-basic-policy</value></entry><entry><key>Shared Access Policy Primary Key</key></entry></properties><runDurationMillis>0</runDurationMillis><schedulingPeriod>0 sec</schedulingPeriod><schedulingStrategy>TIMER_DRIVEN</schedulingStrategy><yieldDuration>1 sec</yieldDuration></config><name>PutAzureEventHub</name><relationships><autoTerminate>false</autoTerminate><description>Any FlowFile that could not be sent to the Azure Event Hub will be transferred to this Relationship.</description><name>failure</name></relationships><relationships><autoTerminate>false</autoTerminate><description>Any FlowFile that is successfully sent to the Azure Event Hub will be transferred to this Relationship.</description><name>success</name></relationships><state>STOPPED</state><style/><supportsEventDriven>false</supportsEventDriven><supportsParallelProcessing>true</supportsParallelProcessing><type>org.apache.nifi.processors.azure.eventhub.PutAzureEventHub</type></processors><processors><id>3619de4c-4748-4fe9-846f-0690f06bfb22</id><parentGroupId>4caac796-d027-4e1b-b1d4-0c7657545225</parentGroupId><position><x>855.0</x><y>197.0</y></position><config><bulletinLevel>WARN</bulletinLevel><comments></comments><concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount><defaultConcurrentTasks><entry><key>TIMER_DRIVEN</key><value>1</value></entry><entry><key>EVENT_DRIVEN</key><value>0</value></entry><entry><key>CRON_DRIVEN</key><value>1</value></entry></defaultConcurrentTasks><defaultSchedulingPeriod><entry><key>TIMER_DRIVEN</key><value>0 sec</value></entry><entry><key>CRON_DRIVEN</key><value>* * * * * ?</value></entry></defaultSchedulingPeriod><descriptors><entry><key>Log Level</key><value><allowableValues><displayName>trace</displayName><value>trace</value></allowableValues><allowableValues><displayName>debug</displayName><value>debug</value></allowableValues><allowableValues><displayName>info</displayName><value>info</value></allowableValues><allowableValues><displayName>warn</displayName><value>warn</value></allowableValues><allowableValues><displayName>error</displayName><value>error</value></allowableValues><defaultValue>info</defaultValue><description>The Log Level to use when logging the Attributes</description><displayName>Log Level</displayName><dynamic>false</dynamic><name>Log Level</name><required>true</required><sensitive>false</sensitive><supportsEl>false</supportsEl></value></entry><entry><key>Log Payload</key><value><allowableValues><displayName>true</displayName><value>true</value></allowableValues><allowableValues><displayName>false</displayName><value>false</value></allowableValues><defaultValue>false</defaultValue><description>If true, the FlowFile's payload will be logged, in addition to its attributes; otherwise, just the Attributes will be logged.</description><displayName>Log Payload</displayName><dynamic>false</dynamic><name>Log Payload</name><required>true</required><sensitive>false</sensitive><supportsEl>false</supportsEl></value></entry><entry><key>Attributes to Log</key><value><description>A comma-separated list of Attributes to Log. If not specified, all attributes will be logged.</description><displayName>Attributes to Log</displayName><dynamic>false</dynamic><name>Attributes to Log</name><required>false</required><sensitive>false</sensitive><supportsEl>false</supportsEl></value></entry><entry><key>Attributes to Ignore</key><value><description>A comma-separated list of Attributes to ignore. If not specified, no attributes will be ignored.</description><displayName>Attributes to Ignore</displayName><dynamic>false</dynamic><name>Attributes to Ignore</name><required>false</required><sensitive>false</sensitive><supportsEl>false</supportsEl></value></entry><entry><key>Log prefix</key><value><description>Log prefix appended to the log lines. It helps to distinguish the output of multiple LogAttribute processors.</description><displayName>Log prefix</displayName><dynamic>false</dynamic><name>Log prefix</name><required>false</required><sensitive>false</sensitive><supportsEl>true</supportsEl></value></entry></descriptors><lossTolerant>false</lossTolerant><penaltyDuration>30 sec</penaltyDuration><properties><entry><key>Log Level</key></entry><entry><key>Log Payload</key></entry><entry><key>Attributes to Log</key></entry><entry><key>Attributes to Ignore</key></entry><entry><key>Log prefix</key></entry></properties><runDurationMillis>0</runDurationMillis><schedulingPeriod>0 sec</schedulingPeriod><schedulingStrategy>TIMER_DRIVEN</schedulingStrategy><yieldDuration>1 sec</yieldDuration></config><name>LogAttribute</name><relationships><autoTerminate>true</autoTerminate><description>All FlowFiles are routed to this relationship</description><name>success</name></relationships><state>STOPPED</state><style/><supportsEventDriven>true</supportsEventDriven><supportsParallelProcessing>true</supportsParallelProcessing><type>org.apache.nifi.processors.standard.LogAttribute</type></processors></snippet><timestamp>08/11/2016 09:15:54 PDT</timestamp></template>
