How to get the ActorSystem in custom operator

[wangpeibin]

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 

[Tzu-Li (Gordon) Tai]

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 <[hidden email]> 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 

[wangpeibin]

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"<[hidden email]>;

发送时间: 2018年11月14日(星期三) 凌晨0:15

收件人: "wpb"<[hidden email]>;

抄送: "user"<[hidden email]>;

主题: 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 <[hidden email]> 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