Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id C0D0F18878 for ; Sat, 23 May 2015 20:26:44 +0000 (UTC) Received: (qmail 81661 invoked by uid 500); 23 May 2015 20:26:44 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 81585 invoked by uid 500); 23 May 2015 20:26:44 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 81575 invoked by uid 99); 23 May 2015 20:26:44 -0000 Received: from Unknown (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 23 May 2015 20:26:44 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 14AD1181A1D for ; Sat, 23 May 2015 20:26:44 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.979 X-Spam-Level: ** X-Spam-Status: No, score=2.979 tagged_above=-999 required=6.31 tests=[HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id K1Os22tOvSfP for ; Sat, 23 May 2015 20:26:41 +0000 (UTC) Received: from COL004-OMC3S11.hotmail.com (col004-omc3s11.hotmail.com [65.55.34.149]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id 7F51120343 for ; Sat, 23 May 2015 20:26:40 +0000 (UTC) Received: from COL129-W18 ([65.55.34.137]) by COL004-OMC3S11.hotmail.com over TLS secured channel with Microsoft SMTPSVC(7.5.7601.22751); Sat, 23 May 2015 13:26:33 -0700 X-TMN: [ejhwOHvuczHkCEYOObsyKLsYA7wxbcjL] X-Originating-Email: [eleroy@msn.com] Message-ID: Content-Type: multipart/alternative; boundary="_ccc49585-4530-47f8-a4ac-0503db243244_" From: Emmanuel To: "user@flink.apache.org" Subject: bug? open() not getting called with RichWindowMapFunction Date: Sat, 23 May 2015 20:26:32 +0000 Importance: Normal MIME-Version: 1.0 X-OriginalArrivalTime: 23 May 2015 20:26:33.0240 (UTC) FILETIME=[C25F4180:01D09596] --_ccc49585-4530-47f8-a4ac-0503db243244_ Content-Type: text/plain; charset="iso-8859-1" Content-Transfer-Encoding: quoted-printable extending AbstractRichFunction gives access to the open function which is c= alled at init if I understand correctly. That works fine with RichMapFunction=2C but with RichWindowMapFunction whic= h also extends AbstractRichFunction the open function never seems to get ca= lled. I also tried extending AbstractRichFunction and implementing AbstractRichFu= nction but that does not help with this.. so it seems like the open functio= n is just never called when setting up a mapWindow transform. I'm using 0.9-milestone1 Is this a bug?Thanks = --_ccc49585-4530-47f8-a4ac-0503db243244_ Content-Type: text/html; charset="iso-8859-1" Content-Transfer-Encoding: quoted-printable

extending =3BA= bstractRichFunction =3Bgives = access to the open function which is called at init if I understand correct= ly.

That works fine with =3BRichMapFunction=2C but with =3BRichWindowMapFunction =3Bwhich also extends =3BAbstractRichFunction =3Bthe =3Bopen =3Bfunction never seems= to get called.

I also tried extending&nb= sp=3BAbstractRichFunction =3Band implementing =3BAbstractRichFunction =3Bbut that does not help with this.. so= it seems like the open function is just never called when setting up a map= Window transform.

<= /span>

I'm using 0.9-milestone= 1

Is this a bug?

Thanks

=3B =3B =3B

= --_ccc49585-4530-47f8-a4ac-0503db243244_--