Thanks, I'll check it out. On Mon, Apr 20, 2020 at 6:23 PM Benchao Li <libenc...@gmail.com> wrote:
> Hi Suraj, > > There is a config option[1] to enable partition discovery, which is > disabled by default. > The community discussed to enable it by default[2], but only aims to the > new Source API. > > [1] > https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#partition-discovery > [2] https://issues.apache.org/jira/browse/FLINK-15703 > > Suraj Puvvada <su...@traceable.ai> 于2020年4月21日周二 上午6:01写道： > >> Hello, >> >> I have a flink job that reads from a source topic that currently has 4 >> partitions and I need to increase the partition count to 8. >> >> Do you need to restart the job for that to take effect ? >> How does it work in case there is persistent state (like a window >> operator) involved ? >> >> Any design documents on how partition mapping works would be very >> helpful. >> >> Thanks >> Suraj >> > > > -- > > Benchao Li > School of Electronics Engineering and Computer Science, Peking University > Tel:+86-15650713730 > Email: libenc...@gmail.com; libenc...@pku.edu.cn > >
