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 4182C200B6B for ; Fri, 9 Sep 2016 10:29:50 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 4042E160AC2; Fri, 9 Sep 2016 08:29:50 +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 8A81A160AB6 for ; Fri, 9 Sep 2016 10:29:49 +0200 (CEST) Received: (qmail 64981 invoked by uid 500); 9 Sep 2016 08:29:48 -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 64972 invoked by uid 99); 9 Sep 2016 08:29:48 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 09 Sep 2016 08:29:48 +0000 Received: from mail-it0-f52.google.com (mail-it0-f52.google.com [209.85.214.52]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 61FE61A0327 for ; Fri, 9 Sep 2016 08:29:48 +0000 (UTC) Received: by mail-it0-f52.google.com with SMTP id i184so6931646itf.0 for ; Fri, 09 Sep 2016 01:29:48 -0700 (PDT) X-Gm-Message-State: AE9vXwPlVbNN2gscQnUkK4gBYX7jiK8cNWxjg5+R58kO+24FG9amAv/3L6MhfPKZye2HDPpTVulkxQKcFL0wPA== X-Received: by 10.157.41.33 with SMTP id d30mr2842882otb.69.1473409787680; Fri, 09 Sep 2016 01:29:47 -0700 (PDT) MIME-Version: 1.0 References: <1473363939426-8975.post@n4.nabble.com> In-Reply-To: <1473363939426-8975.post@n4.nabble.com> From: Aljoscha Krettek Date: Fri, 09 Sep 2016 08:29:37 +0000 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: Firing windows multiple times To: user@flink.apache.org, Vishnu Viswanath Content-Type: multipart/alternative; boundary=94eb2c04f3b800fe46053c0ef339 archived-at: Fri, 09 Sep 2016 08:29:50 -0000 --94eb2c04f3b800fe46053c0ef339 Content-Type: text/plain; charset=UTF-8 Hi, I'd be very happy to give you pointers for FLIP-2 and FLIP-4. Why don't you start a separate thread on the dev list so that we don't hijack this thread. For FLIP-4 we also have to coordinate with Vishnu, he was driving FLIP-4 but lately everyone has been a bit inactive on that. Let's see if he as anything to say, I'll loop him in directly. Cheers, Aljoscha On Thu, 8 Sep 2016 at 21:48 aj.h wrote: > Hi, I'm interested in helping out on this project. I also want to > implement a > continuous time-boxed sliding window, my current use case is a 60-second > sliding window that moves whenever a newer event arrives, discarding any > late events that arrive outside the current window, but *also* > re-triggering > window processing for any late events within the current window. I > considered using sliding windows with a 1-second granularity, but I'd be > discarding a lot of windows on sparse data, and rebuilding pontetially very > large windows for relatively small 1-second updates. > > I'm a fellow in the Insight Data Engineering program. We just got underway, > and I have 3 weeks in which to complete a project. I'd love to tackle this > one, and I'm trying to assess the practicality and feasibility of it. > > I noticed that FLIP-2 and FLIP-4 are still under discussion; is it > premature > to try to implement these enhancements? And would you be at all > willing/available to help me get up to speed? > > Thank you much! > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Firing-windows-multiple-times-tp8424p8975.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. > --94eb2c04f3b800fe46053c0ef339 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi,
I'd be very happy to give you pointers for FLI= P-2 and FLIP-4. Why don't you start a separate thread on the dev list s= o that we don't hijack this thread.

For FLIP-4= we also have to coordinate with Vishnu, he was driving FLIP-4 but lately e= veryone has been a bit inactive on that. Let's see if he as anything to= say, I'll loop him in directly.

Cheers,
=
Aljoscha

On Thu, = 8 Sep 2016 at 21:48 aj.h <drfloob@g= mail.com> wrote:
Hi, I'm= interested in helping out on this project. I also want to implement a
continuous time-boxed sliding window, my current use case is a 60-second sliding window that moves whenever a newer event arrives, discarding any late events that arrive outside the current window, but *also* re-triggerin= g
window processing for any late events within the current window. I
considered using sliding windows with a 1-second granularity, but I'd b= e
discarding a lot of windows on sparse data, and rebuilding pontetially very=
large windows for relatively small 1-second updates.

I'm a fellow in the Insight Data Engineering program. We just got under= way,
and I have 3 weeks in which to complete a project. I'd love to tackle t= his
one, and I'm trying to assess the practicality and feasibility of it.
I noticed that FLIP-2 and FLIP-4 are still under discussion; is it prematur= e
to try to implement these enhancements? And would you be at all
willing/available to help me get up to speed?

Thank you much!



--
View this message in context: http://apache-flink-user-mailin= g-list-archive.2336050.n4.nabble.com/Firing-windows-multiple-times-tp8424p8= 975.html
Sent from the Apache Flink User Mailing List archive. mailing list archive = at Nabble.com.
--94eb2c04f3b800fe46053c0ef339--