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 4970E200C5B for ; Thu, 27 Apr 2017 16:21:35 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 480CC160BA7; Thu, 27 Apr 2017 14:21:35 +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 8F758160B98 for ; Thu, 27 Apr 2017 16:21:34 +0200 (CEST) Received: (qmail 69985 invoked by uid 500); 27 Apr 2017 14:21:28 -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 69955 invoked by uid 99); 27 Apr 2017 14:21:28 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Apr 2017 14:21:28 +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 ED8CE188C40 for ; Thu, 27 Apr 2017 14:21:27 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -2.321 X-Spam-Level: X-Spam-Status: No, score=-2.321 tagged_above=-999 required=6.31 tests=[RCVD_IN_DNSWL_MED=-2.3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id tVxJzTOUh7TZ for ; Thu, 27 Apr 2017 14:21:25 +0000 (UTC) Received: from lhrrgout.huawei.com (lhrrgout.huawei.com [194.213.3.17]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id CD1105F306 for ; Thu, 27 Apr 2017 14:21:24 +0000 (UTC) Received: from 172.18.7.190 (EHLO lhreml705-cah.china.huawei.com) ([172.18.7.190]) by lhrrg02-dlp.huawei.com (MOS 4.3.7-GA FastPath queued) with ESMTP id DFP71910; Thu, 27 Apr 2017 14:21:23 +0000 (GMT) Received: from LHREML503-MBX.china.huawei.com ([10.201.109.55]) by lhreml705-cah.china.huawei.com ([10.201.108.46]) with mapi id 14.03.0301.000; Thu, 27 Apr 2017 15:21:22 +0100 From: Radu Tudoran To: "dev@flink.apache.org" Subject: RE: question about rowtime processfunction - are watermarks needed? Thread-Topic: question about rowtime processfunction - are watermarks needed? Thread-Index: AdK/M2RzisNANSDjTEO1K/Du7rKSiAAHLhuAAARY2NA= Date: Thu, 27 Apr 2017 14:21:20 +0000 Message-ID: <8B754047F81D6B4290B9F4CE928333A517C4B4D5@lhreml503-mbx> References: <8B754047F81D6B4290B9F4CE928333A517C4B3F7@lhreml503-mbx> In-Reply-To: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: x-originating-ip: [10.201.118.108] Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: base64 MIME-Version: 1.0 X-CFilter-Loop: Reflected X-Mirapoint-Virus-RAPID-Raw: score=unknown(0), refid=str=0001.0A020201.5901FE63.0257,ss=1,re=0.000,recu=0.000,reip=0.000,cl=1,cld=1,fgs=0, ip=0.0.0.0, so=2013-06-18 04:22:30, dmn=2013-03-21 17:37:32 X-Mirapoint-Loop-Id: c7a3ce1dd11babd5483b1df1fcef39f9 archived-at: Thu, 27 Apr 2017 14:21:35 -0000 VGhhbmtzIGZvciB0aGUgZXhwbGFuYXRpb24uDQoNCi0tLS0tT3JpZ2luYWwgTWVzc2FnZS0tLS0t DQpGcm9tOiBGYWJpYW4gSHVlc2tlIFttYWlsdG86Zmh1ZXNrZUBnbWFpbC5jb21dIA0KU2VudDog VGh1cnNkYXksIEFwcmlsIDI3LCAyMDE3IDM6MTcgUE0NClRvOiBkZXZAZmxpbmsuYXBhY2hlLm9y Zw0KU3ViamVjdDogUmU6IHF1ZXN0aW9uIGFib3V0IHJvd3RpbWUgcHJvY2Vzc2Z1bmN0aW9uIC0g YXJlIHdhdGVybWFya3MgbmVlZGVkPw0KDQpIaSBSYWR1LA0KDQpldmVudC10aW1lIHByb2Nlc3Np bmcgcmVxdWlyZXMgd2F0ZXJtYXJrcy4gT3BlcmF0b3JzIHVzZSB3YXRlcm1hcmtzIHRvIGNvbXB1 dGUgdGhlIGN1cnJlbnQgZXZlbnQtdGltZS4NClRoZSBQcm9jZXNzRnVuY3Rpb25zIGZvciBvdmVy IHJhbmdlIHdpbmRvd3MgdXNlIHRoZSBUaW1lclNlcnZpY2VzIHRvIGdyb3VwIGVsZW1lbnRzIGJ5 IHRpbWUuDQpJbiBjYXNlIG9mIGV2ZW50LXRpbWUsIHRoZSB0aW1lcnMgYXJlIHRyaWdnZXJlZCBi eSB0aGUgZXZlbnQtdGltZSBvZiB0aGUgb3BlcmF0b3Igd2hpY2ggaXMgZGVyaXZlZCBmcm9tIHRo ZSByZWNlaXZlZCB3YXRlcm1hcmtzLg0KSW4gY2FzZSBvZiBwcm9jZXNzaW5nLXRpbWUsIHRoZSB0 aW1lcnMgYXJlIHRyaWdnZXJlZCBiYXNlZCBvbiB0aGUgd2FsbGNsb2NrIHRpbWUgb2YgdGhlIG9w ZXJhdG9yLg0KDQpTbyBieSB1c2luZyBldmVudC10aW0gdGltZXJzLCB3ZSBpbXBsaWNpdGx5IHJl bHkgb24gdGhlIHdhdGVybWFya3MgYmVjYXVzZSB0aGUgdGltZXJzIGFyZSB0cmlnZ2VyZWQgYmFz ZWQgb24gdGhlIHJlY2VpdmVkIHdhdGVybWFya3MuDQoNCkJlc3QsIEZhYmlhbg0KDQoNCjIwMTct MDQtMjcgMTA6NTEgR01UKzAyOjAwIFJhZHUgVHVkb3JhbiA8cmFkdS50dWRvcmFuQGh1YXdlaS5j b20+Og0KDQo+IEhpLA0KPg0KPiBJIGFtIGxvb2tpbmcgYXQgdGhlIGltcGxlbWVudGF0aW9uIG9m ICBSb3dUaW1lQm91bmRlZFJhbmdlT3ZlciAoaW4gdGhlIA0KPiBjb250ZXh0IG9mIFN0cmVhbSBT UUwpLiBJIHNlZSB0aGF0IHRoZSBsb2dpYyBpcyB0aGF0IHRoZSBwcm9ncmVzcyANCj4gaGFwcGVu cyBiYXNlZCBvbiB0aGUgdGltZXN0YW1wcyBvZiB0aGUgcm93ZXZlbnQgLSBpLmUuLCB3aGVuIGFu IGV2ZW4gDQo+IGFycml2ZXMgd2UgcmVnaXN0ZXIgdG8gYmUgcHJvY2Vzc2VkIGJhc2VkIG9uIGl0 J3MgdGltZXN0YW1wIChjdHgudGltZXJTZXJ2aWNlLg0KPiByZWdpc3RlckV2ZW50VGltZVRpbWVy KHRyaWdnZXJpbmdUcykpDQo+DQo+IEluIHRoZSBvblRpbWVyIHdlIHJlbW92ZSAocmV0cmFjdCkg ZGF0YSB0aGF0IGhhcyBleHBpcmVkLiBIb3dldmVyLCB3ZSANCj4gZG8gbm90IGNvbnNpZGVyIHdh dGVybWFya3Mgbm9yIHNvbWUgYWxsb3dlZCBsYXRlbmN5IGZvciB0aGUgZXZlbnRzIG9yIA0KPiBh bnl0aGluZyBsaWtlIHRoaXMsIHdoaWNoIG1ha2VzIG1lIGFzazoNCj4gRG9uJ3Qgd2UgbmVlZCB0 byB3b3JrIHdpdGggd2F0ZXJtYXJrcyB3aGVuIHdlIGRlYWwgd2l0aCBldmVuIHRpbWU/IEFuZCAN Cj4ga2VlcCB0aGUgZXZlbnRzIHdpdGhpbiB0aGUgYWxsb3dlZCBkZWxheWVkL25leHQgd2F0ZXJt YXJrPyAgQW0gSSANCj4gbWlzc2luZyBzb21ldGhpbmc/IE9yIG1heWJlIHdlIGRvIG5vdCBjb25z aWRlciBhdCB0aGlzIHBvaW50IA0KPiBhbGxvd2VkTGF0ZW5lc3MgIGZvciB0aGlzIHZlcnNpb24/ DQo+DQo+IFRoYW5rcw0KPg0KPiBCZXN0IHJlZ2FyZHMsDQo+DQo+DQo=