JDBC read DB causeOutOfMemoryError: Java heap space

[Qihua Yang]

Hi,

I have a flink cluster(50 hosts, each host runs a task manager).
I am using Flink JDBC to consume data from a database. The db table is
pretty large, around 187340000 rows. I configured the JDBC number of
partitions to 50. fetchSize is 20. Flink application has 50 task managers.
Anyone know why I got OutOfMemoryError? How should I config it?

Thanks,
Qihua