From user-return-18642-archive-asf-public=cust-asf.ponee.io@flink.apache.org Fri Mar 9 06:51:51 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 83E5F180676 for ; Fri, 9 Mar 2018 06:51:50 +0100 (CET) Received: (qmail 40058 invoked by uid 500); 9 Mar 2018 05:51:48 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 39924 invoked by uid 99); 9 Mar 2018 05:51:48 -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; Fri, 09 Mar 2018 05:51:48 +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 334B1180164 for ; Fri, 9 Mar 2018 05:51:48 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.149 X-Spam-Level: ** X-Spam-Status: No, score=2.149 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, MSGID_FROM_MTA_HEADER=0.001, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com 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 wAzhjrf4yjLv for ; Fri, 9 Mar 2018 05:51:47 +0000 (UTC) Received: from mail-io0-f178.google.com (mail-io0-f178.google.com [209.85.223.178]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 346335F195 for ; Fri, 9 Mar 2018 05:51:46 +0000 (UTC) Received: by mail-io0-f178.google.com with SMTP id q24so2312084ioh.8 for ; Thu, 08 Mar 2018 21:51:46 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=from:content-transfer-encoding:mime-version:date:subject :delivered-to:message-id:to; bh=6W/SWqtzGLxHNevz58VzdN5wpFnhuMAjXTTUllKUwZU=; b=UJ0ayukneLVYLBza21yIRFqzuE/ViBnvaj4cwXJOsiyiiWljI2U/bqdtfKwbn9Pu6a bksBw5eJ31Z0yPby9udOIgiZFvRTyNS+yQ7Xf1OjegLfPsnm1lfbZ51/JwueZ55n1CKA vC8T8Iu3HjtknGAYc5OnbYFRpC9MhDwikEz3NdDCl2naROhiGJQO+rVJTzebwhCDsvgX 78QMjvT6p9gb08eH+uHa08qnyZpRfXjOzyyfH8I3bj9BDnOFX6PvV4JSZ/VrPC9WX94E DUoH8Mk2Ka2js6kZV+mKIUxsamrR90y7tMc5n3CjzBlGGqLcJCBtAZ6C1JxkEz5O4dXG Aq7w== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:content-transfer-encoding:mime-version:date :subject:delivered-to:message-id:to; bh=6W/SWqtzGLxHNevz58VzdN5wpFnhuMAjXTTUllKUwZU=; b=SdmyqglJ13OirkPmPRDnEtwEdWEM5PWLzsWJGuV6KTbbfS6Cign+tuoduZMD0ZNlZu PUQwngTmMTF0d/OK/JgtKSeNktyRmtUoNQ1o/PZ1OppK84sBGYKa5Ofkihh7krpHZOyB 0IHWn+pFd40IdxhWrQXvvJwtaujV/fKIAB/dGJXxC4A57lvxqwOftPfYupipUCAjESeC I8Y4dIhoIoo8spBwlHlZap7dSvC+UGlp3fUlDbk/SYpmMcXBI9+JaXpFEYh1J6srm99D RJ+d65GHBwPuEV0h3/KXfWyTLdMPZrNBWnzhM1a5tFkKU+R7f4aIdfD0EaL30euJET1D K0AQ== X-Gm-Message-State: AElRT7G/zieYTVxxzhqNJOfC6uOmo43vCYYEWqhC/E4yzcGiveUve2TX jMymp8jsX3PqqN3+cr1JoswDmrpz X-Google-Smtp-Source: AG47ELuoiHDOitmBCqc/FPptiAMIMDvK48wfmWKn4lBi108hoiuLjasmO6supn1SwSfNtZcAFFs5Tg== X-Received: by 10.107.6.29 with SMTP id 29mr35149791iog.24.1520574704679; Thu, 08 Mar 2018 21:51:44 -0800 (PST) Received: from ?IPv6:2601:445:447f:d571:e8e2:3932:12f4:7c99? ([2601:445:447f:d571:e8e2:3932:12f4:7c99]) by smtp.gmail.com with ESMTPSA id 62sm223606iod.30.2018.03.08.21.51.43 for (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Thu, 08 Mar 2018 21:51:43 -0800 (PST) From: Dhruv Kumar Content-Type: multipart/alternative; boundary=Apple-Mail-9B032F34-777C-4D9D-BA01-714CFCCE1FE2 Content-Transfer-Encoding: 7bit Mime-Version: 1.0 Date: Thu, 8 Mar 2018 23:51:41 -0600 Subject: Emulate Tumbling window in Event Time Space Delivered-To: gargdhruv36@gmail.com Message-Id: <517C2084-4B83-4721-B32A-BA7AD7B465E2@gmail.com> Received: by 10.80.145.166 with HTTP; Thu, 8 Mar 2018 21:35:38 -0800 (PST) To: user@flink.apache.org X-Mailer: iPhone Mail (15E5178f) --Apple-Mail-9B032F34-777C-4D9D-BA01-714CFCCE1FE2 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: quoted-printable Hi I was trying to emulate tumbling window in event time space. Here is the lin= k to my code. I am using the process function to do the custom processing which I want to d= o within every window. I am having an issue of how to emit results at the en= d of every window since my watermark only gets emitted at every incoming eve= nt (incoming event will mostly not intersect with the end time of any window= ). Seems like I need to add a trigger somewhere which fires at the end of ev= ery window. Could any one here help me? Sorry, if I am not clear in anything= . I am quite new to Flink.=20 Thanks Dhruv= --Apple-Mail-9B032F34-777C-4D9D-BA01-714CFCCE1FE2 Content-Type: text/html; charset=utf-8 Content-Transfer-Encoding: 7bit
Hi

I was trying to emulate tumbling window in event time space. Here is the link to my code.
I am using the process function to do the custom processing which I want to do within every window. I am having an issue of how to emit results at the end of every window since my watermark only gets emitted at every incoming event (incoming event will mostly not intersect with the end time of any window). Seems like I need to add a trigger somewhere which fires at the end of every window. Could any one here help me? Sorry, if I am not clear in anything. I am quite new to Flink. 

Thanks
Dhruv
--Apple-Mail-9B032F34-777C-4D9D-BA01-714CFCCE1FE2--