Hi Caizhi, Got it! Thanks for your clarification.
On Tue, Jan 18, 2022 at 11:45 PM Caizhi Weng <tsreape...@gmail.com> wrote: > Hi! > > "But flink application only has 10 task managers". I assume that you're > talking about task slots instead of task managers. > > If there are more partitions than task slots, each task slot may be > assigned more than one partition. By default this is a first come first > served assignment. After a task slot finishes its current partition, it > will ask from the job manager for the next partition unless all partitions > have been distributed. > > Qihua Yang <yang...@gmail.com> 于2022年1月19日周三 14:51写道: > >> 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 >> >