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
>>
>

Reply via email to