[
https://issues.apache.org/jira/browse/FLINK-14146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076485#comment-17076485
]
Sijie Guo commented on FLINK-14146:
---
[~x1q1j1]
[~yijieshen] already sent out
Github user sijie commented on the issue:
https://github.com/apache/flink/pull/6200
wondering anyone from flink community can help review this PR?
---
Github user sijie commented on the issue:
https://github.com/apache/flink/pull/5845
@tzulitai what is your opinion about @XiaoZYang 's comment?
---
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 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 user sijie commented on the issue:
https://github.com/apache/flink/pull/5845
@pluppens thank you for your comments. I was busy with pulsar 2.0 release.
I will try to pick this up again soon :)
---
Github user sijie commented on the issue:
https://github.com/apache/flink/pull/5845
@tzulitai thank you very much for you help. just sent an email to
dev@flink. look forward to feedback from flink community and collaboration
between flink and pulsar communities.
---
Github user sijie commented on the issue:
https://github.com/apache/flink/pull/5845
@tzulitai thank you for your comments. Glad to hear your opinions about
pulsar connectors. I was the original person who initiated the idea of flink
pulsar connectors with @XiaoZYang, I am also from