[
https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414505#comment-17414505
]
Liu commented on FLINK-23969:
-----------------------------
Hello, [~arvid] and [~syhily] . Could you review my code? Thanks.
Since it is a blocker for 1.14.0's releasing, only exclusive and failover
SubscriptionType are tested currently. SubscriptionType Shared and Key_Shared
are both hard to define StopCursor for finishing the flink job and the fetched
data is unordered. So they are more complex and current SourceTestSuiteBase is
not appropriate for them.
I will discuss with [~syhily] for the detail implementation in another ticket
later.
> 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)
