[
https://issues.apache.org/jira/browse/FLINK-2740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14936851#comment-14936851
]
ASF GitHub Bot commented on FLINK-2740:
---------------------------------------
GitHub user bbende opened a pull request:
https://github.com/apache/flink/pull/1198
FLINK-2740 Adding flink-connector-nifi module with NiFiSource and NiF…
To test with a live NiFi instance, do the following:
* Download the latest 0.3.0 release: https://nifi.apache.org/download.html
* Extract it somewhere and edit conf/nifi.properties to set
nifi.remote.input.socket.port=9081
nifi.remote.input.secure=false
* ./bin/nifi.sh start
* Go to http://localhost:8080/nifi/ in your browser
* Click the templates icon in the top right
* Click Browse and select the template in src/test/resources, click Import
* Drag a new template on to the canvas using the Template icon near the top
left
* Press the green Start icon in the toolbar to start all processors
* Run either the NiFiSourceTopology to pull data from NiFi, or the
NiFiSinkTopology to push data
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbende/flink FLINK-2740
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1198.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1198
----
commit 3d588a4e6eb36761f3d708e9fd3bce66cfd23a98
Author: Bryan Bende <[email protected]>
Date: 2015-09-30T13:15:44Z
FLINK-2740 Adding flink-connector-nifi module with NiFiSource and NiFiSink
----
> 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)
