Hi,

I plan to use the database as flink source by using flink JDBC. I know
setNumPartitions can be used for parallelism in table reading.
If the num of task managers is less than numPartitions, what is the
behavior?
For example:
I config setNumPartitions(20), but flink application only has 10 task
managers. How flink assign tasks? Or that is totally wrong configuration?
num of tasks has to be larger than numPartitions?

Thanks,
Qihua

Reply via email to