Details
-
Sub-task
-
Status: Closed
-
Critical
-
Resolution: Fixed
-
None
Description
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.
Attachments
Issue Links
- is blocked by
-
FLINK-23864 The document for Pulsar Source
- Resolved
-
FLINK-23807 Use RestClient to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover
- Resolved
- links to