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,TUMBLE(processtime, INTERVAL'15'SECOND)) AS T
     LEFTJOIN my_dim_table FOR SYSTEM_TIME ASOF T.proc_time AS D ON T.user_id = 
D.user_id
     
     If the partition of the topic is 3, then,the parallelism of the job is 3.
     In this example,there are three operator
         0ne is Source operator, parallelism is 3
         Two is GroupWindowAggregate operator,parallelism is 3
         Three is LookupJoin operator,parallelism is 3


      I want to change the parallelism of GroupWindowAggregate,but i can't.


Best wishes
forideal

Reply via email to