[ https://issues.apache.org/jira/browse/FLINK-9183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fabian Hueske closed FLINK-9183. -------------------------------- Resolution: Fixed Fix Version/s: 1.4.3 1.5.0 Fixed on master with b005ea35374f619298cebab649e0ba477aeaf860 Fixed for 1.5.0 with fc58f987144a307e7208de0bdfe439922bed4b55 Fixed for 1.4.3 with a9b497749710c708d076fc45688fff7b72416af1 Thanks for the contribution [~juho.autio.r] > Kafka consumer docs to warn about idle partitions > ------------------------------------------------- > > Key: FLINK-9183 > URL: https://issues.apache.org/jira/browse/FLINK-9183 > Project: Flink > Issue Type: Sub-task > Reporter: Juho Autio > Assignee: Juho Autio > Priority: Major > Fix For: 1.5.0, 1.4.3 > > > Looks like the bug FLINK-5479 is entirely preventing > FlinkKafkaConsumerBase#assignTimestampsAndWatermarks to be used if there are > any idle partitions. It would be nice to mention in documentation that > currently this requires all subscribed partitions to have a constant stream > of data with growing timestamps. When watermark gets stalled on an idle > partition it blocks everything. > > Link to current documentation: > [https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/kafka.html#kafka-consumers-and-timestamp-extractionwatermark-emission] -- This message was sent by Atlassian JIRA (v7.6.3#76005)