发件人: patricia lee
发送时间: 2023年9月26日 21:30
收件人: 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
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()).trigge
