yes ??I??m trying to have a "signaling" input channel to control the operator
behaviour in the following case.
The StreamOperators will subscribe to the MQ ??not support broadcast?? in the
same group?? One of the operator will receive the massage, then dispatch or
broadcast the message the special operator.
Maybe streaming join will work. but I hope I can use the actor system for more
convenient and controlable.
------------------ ???????? ------------------
??????: "Tzu-Li (Gordon) Tai"<tzuli...@apache.org>;
????????: 2018??11??14??(??????) ????0:15
??????: "wpb"<307558...@qq.com>;
????: "user"<user@flink.apache.org>;
????: 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 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
