[FLINK-3121] Watermark forwarding does not work for sources not producing any data

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Assignee: Aljoscha Krettek
• Reporter: Robert Metzger
• Created: 04/Dec/15 21:20
• Updated: 14/Dec/15 10:50
• Resolved: 11/Dec/15 17:05

Description

This mailing list discussion explains the issue in detail: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Custom-TimestampExtractor-and-FlinkKafkaConsumer082-td3488.html

As a workaround for now, the Kafka source can emit a final watermark for sources not producing any data.