I have a co-process function which goes through a loop and performs the
same task against the input event using different parameters in the state.
So, on the one hand we have the basic input events and on the other the
parameters.

Would that be a good idea to parallelize this task by means of using
completable features since in practice there might be many parameters to be
tried out for each input event?

>From the Flink docs that seems to be discouraged:

https://flink.apache.org/how-to-contribute/code-style-and-quality-common/#5-concurrency-and-threading

but just wondering if someone has tried this out / can provide some
guidance on how to handle this in the most efficient/idiomatic way.

Regards,

Salva

Reply via email to