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
----
---
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.
---
