You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 07:43:00 UTC
[jira] [Commented] (FLINK-8047) Create HTTP Sink
[ https://issues.apache.org/jira/browse/FLINK-8047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16442063#comment-16442063 ]
ASF GitHub Bot commented on FLINK-8047:
---------------------------------------
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 <ge...@...>
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 <ge...@...>
Date: 2018-04-18T07:34:47Z
[FLINK-8047] [http connector] Removed unneeded dependencies
----
> Create HTTP Sink
> ----------------
>
> Key: FLINK-8047
> URL: https://issues.apache.org/jira/browse/FLINK-8047
> Project: Flink
> Issue Type: New Feature
> Components: Batch Connectors and Input/Output Formats
> Reporter: Jessica Negara
> Assignee: Michael Gendelman
> Priority: Major
> Fix For: 1.6.0
>
> Original Estimate: 168h
> Remaining Estimate: 168h
>
> Implement an HTTP output connector + sink, to allow users to send Flink output to an HTTP web server.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)