Currently the groupBy operator need to set max substreams, but the application is streaming application , I can’t get the number of max substreams.
Hi @mggger,
At the risk of binding very much memory, you may set an arbitrarily large value for maxSubstreams
(even Integer.MAX_VALUE
is possible).
Cheers,
Enno.
Thanks for your reply.