Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id A3C55200CC7 for ; Sun, 16 Jul 2017 20:11:37 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id A1B06164183; Sun, 16 Jul 2017 18:11:37 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id DDFD9164180 for ; Sun, 16 Jul 2017 20:11:36 +0200 (CEST) Received: (qmail 51575 invoked by uid 500); 16 Jul 2017 18:11:35 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 51564 invoked by uid 99); 16 Jul 2017 18:11:35 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 16 Jul 2017 18:11:35 +0000 Received: from [192.168.2.104] (p57A8A717.dip0.t-ipconnect.de [87.168.167.23]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 951CA1A0029 for ; Sun, 16 Jul 2017 18:11:34 +0000 (UTC) Subject: Re: Use Flink's actor system To: dev@flink.apache.org References: <7BBE5D37-2B98-45BC-B253-BED37CA87BA2@gmail.com> From: Chesnay Schepler Message-ID: Date: Sun, 16 Jul 2017 20:11:33 +0200 User-Agent: Mozilla/5.0 (Windows NT 10.0; WOW64; rv:52.0) Gecko/20100101 Thunderbird/52.2.1 MIME-Version: 1.0 In-Reply-To: <7BBE5D37-2B98-45BC-B253-BED37CA87BA2@gmail.com> Content-Type: text/plain; charset=windows-1252; format=flowed Content-Transfer-Encoding: 7bit Content-Language: en-US archived-at: Sun, 16 Jul 2017 18:11:37 -0000 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 > > > >