Hi, I don't think that is possible.
Are you trying to "bootstrap" your operator state, or trying to have a "signaling" input channel to control the operator behaviour? If so, there are other better design patterns for these kind of Flink jobs.If possible, you can perhaps briefly describe your use case, then we can figure something out. Cheers, Gordon On Fri, Nov 9, 2018 at 2:31 PM wpb <307558...@qq.com> wrote: > hi， > Since I want to use akka to sync some status in my custom operator，Is > there any way to get the ActorSystem in > org.apache.flink.streaming.api.operators.AbstractStreamOperator or get > the address list of the taskmanager to build the ActorSystem。 > > > thanks >
