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