flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gyula Fóra <gyula.f...@gmail.com>
Subject Flink 1.3 -> 1.4 Kafka state migration issue
Date Mon, 08 Jan 2018 13:46:23 GMT

Is it possible that the Kafka partition assignment logic has changed
between Flink 1.3  and 1.4? I am trying to migrate some jobs using Kafka
0.8 sources and about half my jobs lost offset state for some partitions
(but not all partitions). Jobs with parallelism 1 dont seem to be

Any ideas?


View raw message