Hi Patricia, You are using the .windowall API which generates a global window. This operation is inherently non-parallel since all elements have to pass through the same operator instance so it cannot be set to any parallelism larger than 1.
Best, Zhanghao Chen ________________________________ 发件人: patricia lee <plee3...@gmail.com> 发送时间: 2023年9月26日 21:30 收件人: user@flink.apache.org <user@flink.apache.org> 主题: ProcessWindowFunction Parallelism Hi, Are processwindowfunctions cannot have more than 1 parallelism? Whenever I set it to 2, I am receiving an error message, "The parallelism of non parallel operator must be 1." dataKafka = Kafkasource (datasource) .parallelism(2) .rebalance(); dataKafka.windowAll(GlobalWindows.create()).trigger(MyCountTrigger.of(100)) .process( new CustomTrigger()) .setParallelism(2) ---> error throws here .rebalance()
