Hi,

I am trying to read data from database with JDBC driver. From [1], I have
to config below parameters. I am not quite sure if I understand it
correctly. lower-bound is smallest value of the first partition,
upper-bound is largest value of the last partition. For example, if the db
table has 1000 rows. lower-bound is 0, upper-bound is 999. Is that correct?
If  setting scan.partition.num to 10, each partition read 100 row?
if I set scan.partition.num to 10 and I have 10 task managers. Each task
manager will pick a partition to read?

   - scan.partition.column: The column name used for partitioning the input.
   - scan.partition.num: The number of partitions.
   - scan.partition.lower-bound: The smallest value of the first partition.
   - scan.partition.upper-bound: The largest value of the last partition.

[1]
https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/table/jdbc/

Thanks,
Qihua

Reply via email to