GitHub user genged opened a pull request:
https://github.com/apache/flink/pull/5866
[FLINK-8047] [http connector] Add HTTP Sink to allow sending output to HTTP
server
## What is the purpose of the change
Add HttpSink to enable sending events to an Http server
## Brief change log
- Added a new connector flink-http-connector
- Created HttpSink that allows configuration of the HttpClient and the
ResponseHandler
- The sink sends each element of the stream as a separate HTTP POST
request to the configured server
## Verifying this change
This change added tests and can be verified as follows:
- Added HttpSinkTest that starts a local cluster and an http server
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): yes
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: no
- The serializers: no
- The runtime per-record code paths (performance sensitive): don't know
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Yarn/Mesos, ZooKeeper: no
- The S3 file system connector: no
## Documentation
- Does this pull request introduce a new feature? yes
- If yes, how is the feature documented? JavaDocs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/genged/flink f-8047-http-sink
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/5866.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 #5866
----
commit c62daf8d1228b2e0ea0bec233dc57dfb89d5f592
Author: Michael Gendelman <genged@...>
Date: 2018-04-07T11:10:48Z
[FLINK-8047] [http connector] Add HTTP Sink to allow sending output to HTTP
server
commit df409ab4e7f56d12ccad923abad583d4bdf3cf26
Author: Michael Gendelman <genged@...>
Date: 2018-04-18T07:34:47Z
[FLINK-8047] [http connector] Removed unneeded dependencies
----
---
