From user-return-14257-archive-asf-public=cust-asf.ponee.io@storm.apache.org Thu Dec 6 04:49:41 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id BC0F118062B for ; Thu, 6 Dec 2018 04:49:40 +0100 (CET) Received: (qmail 49738 invoked by uid 500); 6 Dec 2018 03:49:39 -0000 Mailing-List: contact user-help@storm.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@storm.apache.org Delivered-To: mailing list user@storm.apache.org Received: (qmail 49728 invoked by uid 99); 6 Dec 2018 03:49:39 -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; Thu, 06 Dec 2018 03:49:39 +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 C1E35C6F5A for ; Thu, 6 Dec 2018 03:49:38 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.798 X-Spam-Level: * X-Spam-Status: No, score=1.798 tagged_above=-999 required=6.31 tests=[DKIMWL_WL_MED=-0.001, DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, DKIM_VALID_EF=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=yahoo.com Received: from mx1-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 il7DvsYQFYlO for ; Thu, 6 Dec 2018 03:49:34 +0000 (UTC) Received: from sonic313-12.consmr.mail.ne1.yahoo.com (sonic313-12.consmr.mail.ne1.yahoo.com [66.163.185.35]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 288345F188 for ; Thu, 6 Dec 2018 03:49:34 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=yahoo.com; s=s2048; t=1544068167; bh=doDhyseuqfNFBSNlnsWQeLhKNDZyAqe9cQ6Dz3EGPgg=; h=Date:From:To:In-Reply-To:References:Subject:From:Subject; b=AzUUJhYYGlPLHkrkwZYKdTrckS2eW1kU172DMeJxMEmgVj2VYCLXdCEkmddYtp1SHB0xPNR0QcB+4swnNAjzTyE5nwU5anBByYmI/c6cVqPn3DyT4ASW0pYAM2Xlb6FQQpuMKzwMe5ZjtupfWqIKu2KBYgh9A2fVkc8R8dHKkPwaR/8jzRpffW1OLqGgZtn9m3oSaAVuf1l16fsJ3jn3b2ULi+E5L1AhV7ay7IqgWGmYdT1pLNj6B8jajSWQZDX3Bs+8TlV21zBImsH/Wr6YRYhQHNJKjkL4eid2J5a82h4TGbcoxVQUD9EpH3lFbfool1PyQ6pHs9SmXg61+5fpVQ== X-YMail-OSG: 8ZW4QpUVM1k2LUHNtHozmUH2VymNSg1CPohXQbi_DPVljG57BbIVF8kG9tG4vo1 kEsxrw2cGXWf6xHZt0RRolO6g9nj5G.XCpfHu_EsH5ERtlQfXJ7iZD4.WO_pkvMQkyM14k5P_FRo mJkXM4AJ9ciOsk2Id1civ4QQavyX9Cj9VGZbnYwGqvX6Hsz4SYo.yp8Hhht_koqwgZMIIZv6Or9L .QdcT7SOPAykyDx1if7fdTFebXGg10FV9nYARo56Pd_ViUm5DZeQIPTHhPByeZeYgCu38t2oc7GU pLh54IrQdkhUBrOpWAnB9_IpDzchKYg3Hrv30Gh.0Hw2Qz._FRv78vC0.HGdvu.6odwwBM3Ip6LJ DrWCoSLKUd3S96sI1T1Wti1n4wwxflqmg8lqy8Dw4.fQB10cy8luf9ey3nWthAF3WyZYzREtVFQG 3gMCUPdjEwvI9xwEUDzDkCAmGb6JJjXa6IXNAv5P_N2RtCRBOX5KlVmLXVJNZfmkOP1mA.RAEDEi LQX6jJM4_fLZUUyUYpuyBiiul_qD73I0dV4AfG2Xc09LkJp44iKu6pA2uHtCOQ4t_2fwTzx_5GBw g6tsY58HVvDiy8APHIRY3M73vvCKbcdjE3AnSNWPQlGNXHywENM1HwGn0CDvPAxu1C.d6YRNGLcU 8QQFW1VfL71yq4.pOnGJQ4megXTu8J2a74Xd0B5Lizs_KAbzK2MCJ4v51Y75dVwFh470VXrWyR0V GWb_ZKN2kXf5lGZhBitGQn90J2x3BnEeGefPP.0_wFjGPZS0YWkOpcGuFtIKSMvkJC2GpZyFedM7 3A5XU5U.pqQMhQMw2wV_w4OG4C.zphBT5.VT6rUPk1fj9Er3KLw4G.BMQycbFsvK4oEa7zBmYAFs tHY1d2xIgfZcNKqcPjp1V6qFa1jFgWoLjJpFxLTKH4XojhTCYTUJORpZKKlvfZneupWlI2aLklQ6 8qUXYc6gaoV2iBQv63v3i2gEhS1.6KirYZPtXKWtm.9qowyaTKumSDWrHVyIvRW8K6TLPlPaHbLB 576iMvJUZuNzme0JYaoOg4UrdUyJ0i2R1zl7ygYR5v6nxKLY4qfoau6c6xmyQ_TiyBUI_FDKXUGz TgQ6yyGeBFkT_XGtjVleegKcP64sHGrFj0pXeTpS_fIe0ZbW9KmOhfaBA Received: from sonic.gate.mail.ne1.yahoo.com by sonic313.consmr.mail.ne1.yahoo.com with HTTP; Thu, 6 Dec 2018 03:49:27 +0000 Date: Thu, 6 Dec 2018 03:49:25 +0000 (UTC) From: Roshan Naik To: Message-ID: <317050797.2603870.1544068165714@mail.yahoo.com> In-Reply-To: References: Subject: Re: when are the storm window start? MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="----=_Part_2603869_1537204160.1544068165712" X-Mailer: WebService/1.1.12827 YMailNorrin Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.110 Safari/537.36 ------=_Part_2603869_1537204160.1544068165712 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable My recollection is as follows: =C2=A0- the window end time is computed first and that implies the start ti= me.=C2=A0- The window end times for a event is determined based on alignmen= t with the slide interval=C2=A0=C2=A0 =C2=A0 I think this is the relevant c= ode:=C2=A0https://github.com/apache/storm/blob/v1.2.2/storm-core/src/jvm/or= g/apache/storm/windowing/WatermarkTimeTriggerPolicy.java#L110-L116 On Monday, December 3, 2018, 10:22:35 PM PST, ChenBo = wrote: =20 =20 Hi All, I use storm-core=C2=A0 1.2.2, I am little confuse about storm. In document, they say=C2=A0=C2=A0 "When a watermark is received, all window= s up to that timestamp will be evaluated."=20 the question, when are the window start timestamp?=C2=A0=20 Any help is appreciated.Thanks, ChenBo =20 ------=_Part_2603869_1537204160.1544068165712 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
My recollection is as follows:
 - the windo= w end time is computed first and that implies the start time.
&nb= sp;- The window end times for a event is determined based on alignment with= the slide interval 




=20
=20
On Monday, December 3, 2018, 10:22:35 PM PST, ChenBo &l= t;mrchenbo@qq.com> wrote:


Hi All, I use storm-core  1.2.2, I am little confu= se about storm.

In docum= ent, they say   "When a watermark is received, all w= indows up to that timestamp will be evaluated."

the question, when are the window start timest= amp? 

Any help is appreciated. 
Thanks,

ChenBo
=
------=_Part_2603869_1537204160.1544068165712--