[
https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414715#comment-17414715
]
Xintong Song commented on FLINK-23969:
--------------------------------------
[~syhily],
I don't think I'm the right person to review this. My knowledge in Pulsar and
the Flink Pulsar connector is far from enough to be responsible for the quality
of this PR.
I'll try to find someone.
> Test Pulsar source end 2 end
> ----------------------------
>
> Key: FLINK-23969
> URL: https://issues.apache.org/jira/browse/FLINK-23969
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / Pulsar
> Reporter: Arvid Heise
> Assignee: Liu
> Priority: Blocker
> Labels: pull-request-available, release-testing
> Fix For: 1.14.0
>
>
> Write a test application using Pulsar Source and execute it in distributed
> fashion. Check fault-tolerance by crashing and restarting a TM.
> Ideally, we test different subscription modes and sticky keys in particular.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
