Thanks for the report, I will take a look. > Am 06.09.2017 um 11:48 schrieb Gyula Fóra <gyf...@apache.org>: > > Hi all, > > We are running into some problems with the kafka source after changing the > uid and restoring from the savepoint. > What we are expecting is to clear the partition state, and set it up all over > again, but what seems to happen is that the consumer thinks that it doesnt > have any partitions assigned. > > This was supposed to be fixed in > https://github.com/apache/flink/commit/0ecb5d0050b84ba48105836288d43ce4c4749459#diff-06bf4a7f73d98ef91309154654563475 > > <https://github.com/apache/flink/commit/0ecb5d0050b84ba48105836288d43ce4c4749459#diff-06bf4a7f73d98ef91309154654563475> > but appears to be reworked/reverted in the latest release : > https://github.com/apache/flink/blob/0399beed1ea3e04d332b42cc506041d75a6148b4/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java#L547 > > <https://github.com/apache/flink/blob/0399beed1ea3e04d332b42cc506041d75a6148b4/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java#L547> > > What is the expected behaviour here? > > Thanks! > Gyula
- Empty state restore seems to be broken for Kafka source (... Gyula Fóra
- Re: Empty state restore seems to be broken for Kafka... Stefan Richter
- Re: Empty state restore seems to be broken for K... Aljoscha Krettek
- Re: Empty state restore seems to be broken f... Gyula Fóra
- Re: Empty state restore seems to be brok... Aljoscha Krettek
- Re: Empty state restore seems to be... Aljoscha Krettek
- Re: Empty state restore seems t... Aljoscha Krettek
- Re: Empty state restore see... Gyula Fóra
- Re: Empty state restore see... Gyula Fóra
- Re: Empty state restore see... Aljoscha Krettek
- Re: Empty state restore see... Gyula Fóra
- Re: Empty state restore see... Aljoscha Krettek