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 >
