[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 issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

2018-05-20 Thread XiaoZYang
Github user XiaoZYang commented on the issue: https://github.com/apache/flink/pull/5845 @sijie would you mind help reviewing this commit? ---

[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 issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

2018-05-21 Thread XiaoZYang
Github user XiaoZYang commented on the issue: https://github.com/apache/flink/pull/5845 ping @sijie ---

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

2018-06-08 Thread XiaoZYang
Github user XiaoZYang commented on the issue: https://github.com/apache/flink/pull/5845 @tzulitai @surryr @pluppens @sijie This PR is going to be closed and I will open another PR to brunch pulsar-connector to this issue. ---

[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 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 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 issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

2018-06-14 Thread XiaoZYang
Github user XiaoZYang commented on the issue: https://github.com/apache/flink/pull/5845 @hsaputra There is no error but the issue is 1. when I create a PR to the flink repo from my fork repo I need to choose a branch to which the commits are merged to 2. I'm expected

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

2018-06-14 Thread XiaoZYang
Github user XiaoZYang commented on the issue: https://github.com/apache/flink/pull/5845 I prefer to open a new PR and a new branch. But I am not authorized to do that. ---

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

2018-06-14 Thread XiaoZYang
Github user XiaoZYang commented on the issue: https://github.com/apache/flink/pull/5845 @zentol got it! So what you mean is that @sijie and I will keep updating commits until this work is done and you guys will merge this PR to a new branch. Later PR will be against the new branch

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

2018-06-02 Thread XiaoZYang
Github user XiaoZYang commented on the issue: https://github.com/apache/flink/pull/5845 Hi @sijie @tzulitai, since there will be serial of commits about *pulsar connector*, what about close this pr and reopen a new PR which is going to merge to a new branch named "pulsar-conn

[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