I have two sources (s3) that I read using

Table.createTemporaryTable

... One source has 24 small folders each with one file and the other source is huge with one folder containing many files. So in total I have 25 tables. When I run it in Flink it spawns all tasks with 1 parallelism..How can I make it run one source (24 tables) with 1 parallelism and the other with higher parallelism. I was expecting Flink to automatically do this like Spark but it doesnt?