lt;307558...@qq.com>;
????: "user";
????: Re: How to get the ActorSystem in custom operator
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 beh
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
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
