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 D1BC2200B6B for ; Fri, 9 Sep 2016 19:42:05 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id D03A0160AC2; Fri, 9 Sep 2016 17:42:05 +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 F3E50160AA3 for ; Fri, 9 Sep 2016 19:42:04 +0200 (CEST) Received: (qmail 6195 invoked by uid 500); 9 Sep 2016 17:41:59 -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 6184 invoked by uid 99); 9 Sep 2016 17:41:59 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 09 Sep 2016 17:41:59 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id AA5F6CABDB for ; Fri, 9 Sep 2016 17:41:58 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.742 X-Spam-Level: ** X-Spam-Status: No, score=2.742 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001, URI_HEX=1.313] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx2-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id sx1NMJ0obvTU for ; Fri, 9 Sep 2016 17:41:56 +0000 (UTC) Received: from mail-vk0-f51.google.com (mail-vk0-f51.google.com [209.85.213.51]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with ESMTPS id D08945FB2D for ; Fri, 9 Sep 2016 17:41:55 +0000 (UTC) Received: by mail-vk0-f51.google.com with SMTP id f76so75029432vke.0 for ; Fri, 09 Sep 2016 10:41:55 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=cFJvOhNu6nJ7CVD+cvgx5sKpqMF5JuDwKHs/0BNEoe0=; b=Gc0wTqOOICsrheU3IIbdkZMws/jMTNq7RmOU6H275EYWahENSjsfTA7VPFaiDoo7Aq tfCY/W+xWGUDHimntVJjcwpjNpYZ5d4nZJKrD6Gd+P1mBs4uPXolnSw9WuoTokq6dSmL hxtk4IBWwfyQeIJg71xJGakT95e5yWH3QXHMRvAxUspaTI6TCPJT4cHhoB2a9Wuq9wq4 19DBVgn9NpIra8RBK/zZ2HHd2wjak0gMaI+dTFs1pfeV9o97yu5MKlkm1YHXZTlGHCY2 raTAML2hHby57d0y1lamiZYSLCrvUy3ack5QHo1DCANkmOo1cB1r7CwM1FgcIHuOMFlZ Wcbw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=cFJvOhNu6nJ7CVD+cvgx5sKpqMF5JuDwKHs/0BNEoe0=; b=FM4PshI9UQMvMKxQXxgyYx8+AnMyEkiH0VhHAkq4MTpGgt/8gd7efKuJSs5tY85z9D NOFurB8WPEjhnohaSlJRo8eas1v9aq9tBClEyyyTC7kX+HLQdBY27NvyAI8NxFNXwZBx 7CC7qc7FRFR/jFqGtBT6sOQG9VOGnJoLemrBvgBO3zdXdjumlBJYHyfqDknLfXXHPTWD iCnxzXYaj89f23I78C6yQINwLhis8yO2FqFFYYhjLpgSw5ZixAWgBrA2WusiJoROXWsN GF/pX8v7p7hJlAoRvd4jgwaHribph0j5WLGCcZgjHsOv+F1EK7Vc7TR5irRNkBrUDQGO TUog== X-Gm-Message-State: AE9vXwN96OrZuvEa0lZ0depjzBlWv5WNB+Wm4LBRNsUkpwoI84x0aJ1tvrW878p0PpQ0+3e74YKX9tJd1OimNw== X-Received: by 10.31.15.139 with SMTP id 133mr3391468vkp.37.1473442914607; Fri, 09 Sep 2016 10:41:54 -0700 (PDT) MIME-Version: 1.0 Received: by 10.176.2.114 with HTTP; Fri, 9 Sep 2016 10:41:33 -0700 (PDT) In-Reply-To: References: <1473363939426-8975.post@n4.nabble.com> From: Vishnu Viswanath Date: Fri, 9 Sep 2016 12:41:33 -0500 Message-ID: Subject: Re: Firing windows multiple times To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a1143aee685d7f6053c16a9eb archived-at: Fri, 09 Sep 2016 17:42:06 -0000 --001a1143aee685d7f6053c16a9eb Content-Type: text/plain; charset=UTF-8 Hi, Sorry, I was little busy lately. I have most part of FLIP-4 ready except ProcessingTimeEvictor case. I was trying to find the best way to set the ProcessingTime as per the suggestion from Aljoscha then I got busy with some other work. We can definitely work together on that. Thanks Vishnu On Fri, Sep 9, 2016 at 3:29 AM, Aljoscha Krettek wrote: > 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. >> > --001a1143aee685d7f6053c16a9eb Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi,

Sorry, I was little busy lately.=C2= =A0
I have most part of FLIP-4 ready except ProcessingTimeEvictor= case. I was trying to find the best way to set the ProcessingTime as per t= he suggestion from Aljoscha then I got busy with some other work.=C2=A0

We can definitely work together on that.

Thanks
Vishnu

On Fri, Sep 9, 2016 at 3:29 AM, Aljoscha Krettek <aljos= cha@apache.org> wrote:
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 th= at we don't hijack this thread.

For FLIP-4 we = also have to coordinate with Vishnu, he was driving FLIP-4 but lately every= one 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@gmail.com> wrote:
Hi, I'm interested in helping out on this pro= ject. 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-m= ailing-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.

--001a1143aee685d7f6053c16a9eb--