ProcessWindowFunction Parallelism

[patricia lee]

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