Re: SQL parallelism setting

2018-08-10 Thread Timo Walther
Hi, currenlty, you can only set the parallelism for an entire Flink job using env.setParallelism(). There are rough ideas of how we could improve the situation in the future to control the parallelism of individual operators but this might need one or two releases. Regards, Timo Am 10.08.

SQL parallelism setting

2018-08-09 Thread Shu Li Zheng
Hi community, Is there a way to change parallelism on sqlQuery()? Regards, Shu li Zheng