Re: Flink SQL, How can i set parallelism in clause of group by ?

2020-03-17 Thread Benchao Li
Hi forideal, Currently, there is no way to change an operator's parallelism for SQL. All operators use global parallelism as their parallelism, except for some 'global operator' which can only has parallelism of 1. BTW, does changing the parallelism of all operators meets your need? forideal 于2

Flink SQL, How can i set parallelism in clause of group by ?

2020-03-17 Thread forideal
Hello everyone I'm a Flink SQL user. Now i have a question.How can i set parallelism in clause of group by. For example SELECT T.user_id, D.user_name (SELECT user_id, MIN(processtime) from my_table group by user_id