[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-06-08 Thread XiaoZYang
GitHub user XiaoZYang reopened 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. ##

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-06-08 Thread XiaoZYang
Github user XiaoZYang closed the pull request at: https://github.com/apache/flink/pull/5845 ---

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-06-08 Thread XiaoZYang
Github user XiaoZYang commented on a diff in the pull request: https://github.com/apache/flink/pull/5845#discussion_r194076473 --- Diff: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducer.java --- @@ -0,0 +1,304

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-06-07 Thread surryr
Github user surryr commented on a diff in the pull request: https://github.com/apache/flink/pull/5845#discussion_r193793061 --- Diff: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducer.java --- @@ -0,0 +1,304 @@

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-05-21 Thread XiaoZYang
GitHub user XiaoZYang reopened 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. ##

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-05-20 Thread XiaoZYang
Github user XiaoZYang closed the pull request at: https://github.com/apache/flink/pull/5845 ---

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-05-17 Thread sijie
Github user sijie commented on a diff in the pull request: https://github.com/apache/flink/pull/5845#discussion_r188867505 --- Diff: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarProduceMode.java --- @@ -0,0 +1,36 @@

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-05-17 Thread sijie
Github user sijie commented on a diff in the pull request: https://github.com/apache/flink/pull/5845#discussion_r188867435 --- Diff: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducerTest.java --- @@ -0,0 +1,100

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-05-09 Thread pluppens
Github user pluppens commented on a diff in the pull request: https://github.com/apache/flink/pull/5845#discussion_r187085104 --- Diff: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducerTest.java --- @@ -0,0

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-05-09 Thread pluppens
Github user pluppens commented on a diff in the pull request: https://github.com/apache/flink/pull/5845#discussion_r187084563 --- Diff: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarProduceMode.java --- @@ -0,0 +1,36 @@

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-04-13 Thread XiaoZYang
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. ##