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

Posted by forideal on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-SQL-How-can-i-set-parallelism-in-clause-of-group-by-tp33736.html

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

     LEFT JOIN my_dim_table FOR SYSTEM_TIME AS OF 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