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
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