Hi Caizhi,
Got it! Thanks for your clarification.
On Tue, Jan 18, 2022 at 11:45 PM Caizhi Weng 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 tas
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 tas
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
