Re: Empty state restore seems to be broken for Kafka source (1.3.2)

[Stefan Richter]

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