Please ignore, last Email, Its working now by adding more parallelism.
On Fri, Aug 28, 2020 at 12:39 PM Vijayendra Yadav
wrote:
> Hi Team,
>
>
> https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/config.html#configuring-taskmanager-processing-slots
>
>
> In my Flinkkafkaconsumer st
Hi Team,
https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/config.html#configuring-taskmanager-processing-slots
In my Flinkkafkaconsumer streaming process. I have kafka with 3
partitions.
I am getting parallelism = 3 (-p 3). Here 3 taskmangers are launched but
each taskmanager g
