[ https://issues.apache.org/jira/browse/FLINK-23704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408257#comment-17408257 ]
Nicholas Jiang commented on FLINK-23704: ---------------------------------------- [~pnowojski], I have pushed the PR for the LatencyMarkerEmitter in SourceOperator. Please help to review this PR. > FLIP-27 sources are not generating LatencyMarkers > ------------------------------------------------- > > Key: FLINK-23704 > URL: https://issues.apache.org/jira/browse/FLINK-23704 > Project: Flink > Issue Type: Bug > Components: API / DataStream, Runtime / Task > Affects Versions: 1.14.0, 1.12.5, 1.13.2 > Reporter: Piotr Nowojski > Priority: Major > Labels: pull-request-available > > Currently {{LatencyMarker}} is created only in > {{StreamSource.LatencyMarksEmitter#LatencyMarksEmitter}}. FLIP-27 sources are > never emitting it. -- This message was sent by Atlassian Jira (v8.3.4#803005)