flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetzger <...@git.apache.org>
Subject [GitHub] flink pull request: FLINK-2740 Adding flink-connector-nifi module ...
Date Thu, 01 Oct 2015 10:26:44 GMT
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message