Hi all, Any update on this?
Best, Mason On Sat, Oct 30, 2021 at 5:56 AM Arvid Heise <ar...@apache.org> wrote: > This seems to be a valid concern but I'm not deep enough to clearly say > that this is indeed a bug. @renqschn <renqs...@gmail.com> could you > please double-check? > > On Thu, Oct 28, 2021 at 8:39 PM Mason Chen <mas.chen6...@gmail.com> wrote: > >> Hi all, >> >> I noticed that the KafkaSourceReader did not have a pointer to the >> KafkaSubscriber, so I was wondering if this could be a bug: >> >> 1. User has a flink job with topic set A and takes savepoint >> 2. User modifies flink job to read from topic set B; however, splits are >> still read from topic set A (since there’s no logic to filter/remove >> splits). >> >> To clarify, I haven’t tested this scenario out myself, but just through >> reading the code, there was no logic to filter/remove splits. Just to add >> and complete. >> >> Best, >> Mason >> >
