flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2740) Create data consumer for Apache NiFi
Date Thu, 01 Oct 2015 15:28:28 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14939966#comment-14939966
] 

ASF GitHub Bot commented on FLINK-2740:
---------------------------------------

Github user rmetzger commented on the pull request:

    https://github.com/apache/flink/pull/1198#issuecomment-144762615
  
    Thank you for looking into it. 
    Your analysis was right: I've accidentally put the port into the host parameter `nifi.remote.input.socket.host=9081`.

    After I've changed it, everything was working: https://www.youtube.com/watch?v=ylnv5p5Ddk8
    
    In my local setup, it seems that only one of my 8 parallel instances of the source are
actually reading data. I suspect that Nifi is delivering data only to one reader.
    
    How would that work in a cluster? How does Nifi know that all the Flink `NifiSource`s
connecting to Nifi belong to the same system? 



> Create data consumer for Apache NiFi
> ------------------------------------
>
>                 Key: FLINK-2740
>                 URL: https://issues.apache.org/jira/browse/FLINK-2740
>             Project: Flink
>          Issue Type: New Feature
>          Components: Streaming Connectors
>            Reporter: Kostas Tzoumas
>            Assignee: Joseph Witt
>
> Create a connector to Apache NiFi to create Flink DataStreams from NiFi flows



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message