[
https://issues.apache.org/jira/browse/BAHIR-134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143347#comment-16143347
]
ASF GitHub Bot commented on BAHIR-134:
--------------------------------------
GitHub user yew1eb opened a pull request:
https://github.com/apache/bahir-flink/pull/21
[BAHIR-134] Add InfluxDB sink for flink stream
add InfluxDBSink for flink stream
## Verifying this change
Add example `InfluxDBSinkExample`
Runing environment:
flink version 1.3.0
influxdb version: 1.3.4
influxdb-java(influxdb client) version: 2.7(Compatible with InfluxDB
version 0.9 ~ 1.3.x)
It works well.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/yew1eb/bahir-flink BAHIR-134
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/bahir-flink/pull/21.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 #21
----
commit 1249a8c26fa261719431a269f4b46203e748774f
Author: zhouhai02 <[email protected]>
Date: 2017-08-27T11:35:31Z
add InfluxDb sink for flink stream
----
> Add InfluxDB Sink for Flink Streaming
> -------------------------------------
>
> Key: BAHIR-134
> URL: https://issues.apache.org/jira/browse/BAHIR-134
> Project: Bahir
> Issue Type: Wish
> Components: Flink Streaming Connectors
> Reporter: Hai Zhou
> Assignee: Hai Zhou
>
> InfluxDBSink via implementation RichSinkFunction.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
