Hi. I have some question about increase kafka partition. If I have Flink application running using Flink Table API and set parallelism to be 8. Then, I increase Kafka partition from 8 to 16. I know that Flink can discover new partition but, will there be any impact to running application e.g. Flink state and etc if I have window group in my application.

Yes, there currently would be impact. This is going to be addressed with https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source