[FLINK-23704] FLIP-27 sources are not generating LatencyMarkers - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: Closed
Priority: Major
Resolution: Fixed
Affects Version/s: 1.14.0, 1.12.5, 1.13.2
Fix Version/s: 1.13.3, 1.12.8, 1.14.3, 1.15.0
Component/s: API / DataStream, Runtime / Task
Labels:
- pull-request-available

Description

Currently LatencyMarker is created only in StreamSource.LatencyMarksEmitter#LatencyMarksEmitter. FLIP-27 sources are never emitting it.

Attachments

Issue Links

links to

GitHub Pull Request #17105

Activity

People

Assignee:: Nicholas Jiang

Reporter:: Piotr Nowojski

Votes:: 0 Vote for this issue

Watchers:: 2 Start watching this issue

Dates

Created:: 10/Aug/21 09:31

Updated:: 15/Dec/21 01:44

Resolved:: 15/Oct/21 08:38