Migrating the jobs by setting the sources to parallelism = 1 and then scale back up after migration seems to be a good workaround, but I am wondering if something I do made this happen or this is a bug.
Gyula Fóra <gyula.f...@gmail.com> ezt írta (időpont: 2018. jan. 8., H, 14:46): > Hi, > > 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 > affected... > > Any ideas? > > Gyula >
