flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Suraj Puvvada <su...@traceable.ai>
Subject Changing number of partitions for a topic
Date Mon, 20 Apr 2020 22:01:22 GMT

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.


View raw message