[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16437601#comment-16437601 ]
ASF GitHub Bot commented on FLINK-9168: --------------------------------------- GitHub user XiaoZYang opened a pull request: https://github.com/apache/flink/pull/5845 [FLINK-9168][flink-connectors]Pulsar Sink connector ## What is the purpose of the change Provide a [pulsar](https://github.com/apache/incubator-pulsar) sink connector for flink. ## Brief change log - add `PulsarTableSink` - add `PulsarJsonTableSink` ## Verifying this change Added test that validates that target classses (i.e. PulsarTableSink and PulsarJsonTableSink) work as expected ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (yes ) upgrade `org.javassist` version to 3.20.0-GA - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (no) - The serializers: (don't know) - 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: (don't know) ## 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/XiaoZYang/flink pulsar-connector Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/5845.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 #5845 ---- commit fff36440197e3f34caf3af0b7ed7ba5320003e3b Author: Sijie Guo <sijie@...> Date: 2018-03-02T05:08:53Z Add pulsar flink connector commit 447a998ce9d4de2dbb7b099b0568c5aed9f374bd Author: xiaozongyang <xiaozongyang@...> Date: 2018-04-13T07:51:49Z 1.update pom.xml to follow flink version ---- > Pulsar Sink Connector > --------------------- > > Key: FLINK-9168 > URL: https://issues.apache.org/jira/browse/FLINK-9168 > Project: Flink > Issue Type: New Feature > Components: Streaming Connectors > Affects Versions: 1.6.0 > Reporter: Zongyang Xiao > Priority: Minor > Fix For: 1.6.0 > > > Flink does not provide a sink connector for Pulsar. -- This message was sent by Atlassian JIRA (v7.6.3#76005)