Hi,

I need to do set/initialize some config of a framework/util that is used in
my Flink stream processing app. Basically, a piece of code that needs to be
executed exactly once before anything else. Clearly doing it in the main
flink processor function will not suffice, as apart from the client, the
same needs to be done on other node before topology is executed.

I have gone through Flink best practices
<https://ci.apache.org/projects/flink/flink-docs-master/monitoring/best_practices.html>,
and one way I can think about it to check whether init has been done in the
open() all Rich Functions, and if not then call the initialization code.
But that seems to be "right", basically to add any operator, I must do this
initillazation call boilerplate code.

Is there anyway to define a global initializations in Flink, or to define
an operator that is guaranteed to be called the first thing on all nodes?

Thanks,
+satish

Reply via email to