Use Flink's actor system

[Lorenzo Affetti <lo...@gmail.com>]

Hello everybody,

I want to do some experiments with communication across operators.
Even if arguable, I wondered if it is possible to directly use the clustered actor system used by Flink.
If so, how can I get an instance of the actor system in an Operator?

Thank you in advance

Lorenzo Affetti

Re: Use Flink's actor system

[affo <lo...@gmail.com>]

Thank you Chesnay and Till.

Best,
Lorenzo



--
View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Use-Flink-s-actor-system-tp18709p18942.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.

Re: Use Flink's actor system

[Till Rohrmann <tr...@apache.org>]

Hi Lorenzo,

apart from experimentation it's not recommended to directly use Flink's
ActorSystem, because it is an implementation detail. With Flip-6 the
ActorSystem will be further hidden and in the future we might implement a
different RPC system not relying on Akka.

Cheers,
Till

On Sun, Jul 16, 2017 at 8:11 PM, Chesnay Schepler <ch...@apache.org>
wrote:

> Hello,
>
> I don't think the actor system is exposed to operators in any way.
>
> If you want to access it whatever it may take (reflection etc.) you could
> try working your way through the metric group (through the runtime context)
> into the MetricRegistry and from the into the MetricQueryService.
>
> Regards,
> Chesnay
>
>
> On 12.07.2017 17:05, Lorenzo Affetti wrote:
>
>> Hello everybody,
>>
>> I want to do some experiments with communication across operators.
>> Even if arguable, I wondered if it is possible to directly use the
>> clustered actor system used by Flink.
>> If so, how can I get an instance of the actor system in an Operator?
>>
>> Thank you in advance
>>
>> Lorenzo Affetti
>>
>>
>>
>>
>>
>

Re: Use Flink's actor system

[Chesnay Schepler <ch...@apache.org>]

Hello,

I don't think the actor system is exposed to operators in any way.

If you want to access it whatever it may take (reflection etc.) you 
could try working your way through the metric group (through the runtime 
context) into the MetricRegistry and from the into the MetricQueryService.

Regards,
Chesnay

On 12.07.2017 17:05, Lorenzo Affetti wrote:
> Hello everybody,
>
> I want to do some experiments with communication across operators.
> Even if arguable, I wondered if it is possible to directly use the clustered actor system used by Flink.
> If so, how can I get an instance of the actor system in an Operator?
>
> Thank you in advance
>
> Lorenzo Affetti
>
>
>
>