is there any way to set a different parallelism for specific tables? currently i use:

tEnv.getConfig()        // access high-level configuration
  .getConfiguration()   // set low-level key-value options
  .setString("table.exec.resource.default-parallelism", ***parallelism***)

but I want to set parallelism to 2 for table sources (upsert-kafka, there's only two partitions in these kafka topics), and 4 for everything else (joins, etc.) I create the upsert-kafka source tables using

TableDescriptor

and then

tableEnv.createTable(name, descriptor)