Hi Team,

I am currently running Flink 1.16.3 with Apache Beam to run our batch jobs.
We are trying to process the data with an input size of over 20 million,
but unfortunately, it is failing.
we want Flink to handle the parallelism based on input load automatically
but even with -1 configuration, we have observed that the parallelism was
set to 1 and SDK workers were not automatically scaling.
we tried all sorts of configurations and their combinations but could not
get the desired result.

Is there some bug concerning parallelism in the 1.16.3 version?

Thanks,
Suraj

Reply via email to