Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1198#issuecomment-144688632
I followed the tutorial for Nifi that you posted into the pull request.
Thanks a lot for the good instructions. I was able to start it and get it to
run in a few minutes.
However, when starting the source topology, I got the following error:
```
10/01/2015 12:23:47 Source: Custom Source -> Map -> Sink: Unnamed(2/8)
switched to RUNNING
10/01/2015 12:23:47 Source: Custom Source -> Map -> Sink: Unnamed(4/8)
switched to FAILED
java.lang.NullPointerException
at
org.apache.flink.streaming.connectors.nifi.NiFiSource.run(NiFiSource.java:65)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:57)
at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:57)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:198)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:579)
at java.lang.Thread.run(Thread.java:745)
```
it seems that the `final Transaction transaction =
client.createTransaction(TransferDirection.RECEIVE);` call is returning null.
This is what my NiFi screen looks like: http://i.imgur.com/FDFgrdu.png
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
