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 0A577200C05 for ; Mon, 9 Jan 2017 06:12:56 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 0905E160B45; Mon, 9 Jan 2017 05:12:56 +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 53F96160B36 for ; Mon, 9 Jan 2017 06:12:55 +0100 (CET) Received: (qmail 86749 invoked by uid 500); 9 Jan 2017 05:12:53 -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 86737 invoked by uid 99); 9 Jan 2017 05:12:52 -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; Mon, 09 Jan 2017 05:12:52 +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 F077E1800B9 for ; Mon, 9 Jan 2017 05:12:51 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.992 X-Spam-Level: ** X-Spam-Status: No, score=2.992 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001, URI_HEX=1.313] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id RLIEMNT2VbR6 for ; Mon, 9 Jan 2017 05:12:49 +0000 (UTC) Received: from mail-qk0-f174.google.com (mail-qk0-f174.google.com [209.85.220.174]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 9CEC55F370 for ; Mon, 9 Jan 2017 05:12:49 +0000 (UTC) Received: by mail-qk0-f174.google.com with SMTP id s140so107293404qke.0 for ; Sun, 08 Jan 2017 21:12:49 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=7xkGyB02WdWkqdcaaXYubjVar4zLDmkagbZpzxl+Df0=; b=FAesbtMbsb7IUxUjcHRfG2YrdoZIOI1EBOXZX/Ay0P9ougGd0sVDAohZy2wN6HZO48 NOm7dsaMVNojdLvboQcyMaxWmKGimhL2rc9Q3O4kkvaYqw4GNenYnwRStxqXlJsuaUi1 Manueg4ZxXlvgMGuu+pNa+c34LOprfYYjLiRu+bl9pZH/xVBwiqxthjJktZUNBaJxrdF RjQfDvuxGjJum1rpkC2Xxi3hBL1IZ17iCvZi+5kzShTKYIuEFflOLcIQkmhza32wQN5C lFpVvd64+VjCIMowFH2cIWNzvRKXd2xfAk6xJVfcTZwmwj9HaIRBjWEkw+62aRBTkT40 vL4A== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=7xkGyB02WdWkqdcaaXYubjVar4zLDmkagbZpzxl+Df0=; b=QfdrbcEi1eXwdgsjDZHL1OdqYLLfz7lrePw5deOU7jdDludq78cifeF80tDtL5pqE9 /douMzEKytFSiax+Rgh0LhNNYgyJi9BZplaLQa+9jTE755t372tUcUjXUd2SaSqBm8Sa PwKUXrtIIXIFNX9JOi+4EydFme1UTsSkRcbCDn7xJ+YMvwhag1gQfiGNpPfMzb1boYn6 9QDKxpgfUnbDrNOGRG+TCziE/e3cxLFikIaWvjpylo8KgRjdVK0sOVL/ZtaBm0fF07HI EuZEaaMSr9jD1PBAVsY4r7EzK+jWoo2Z+wkyqbhZSpAw3PpG4B/So7CtTRiKiNf/ijLT 2jhA== X-Gm-Message-State: AIkVDXISFiRuqEAqNMAHiEUdLWeIgjJbh2xlTi0YeIBVXVzYT0pfAkAWZmmO5QIvNItA/fpCsLCpw6uBVsayCg== X-Received: by 10.55.167.8 with SMTP id q8mr20705057qke.97.1483938763563; Sun, 08 Jan 2017 21:12:43 -0800 (PST) MIME-Version: 1.0 Received: by 10.55.141.2 with HTTP; Sun, 8 Jan 2017 21:12:43 -0800 (PST) In-Reply-To: <1483814846061-15173.post@n3.nabble.com> References: <1483697122277-15164.post@n3.nabble.com> <1483814846061-15173.post@n3.nabble.com> From: Alexey Demin Date: Mon, 9 Jan 2017 09:12:43 +0400 Message-ID: Subject: Re: DataStream and CEP - Pattern not matching after applying a window To: dev@flink.apache.org Content-Type: multipart/alternative; boundary=001a114fdd18df06db0545a26a17 archived-at: Mon, 09 Jan 2017 05:12:56 -0000 --001a114fdd18df06db0545a26a17 Content-Type: text/plain; charset=UTF-8 Hi Because flink use lazy evaluation and because inactivityCEP don't have any output then you pattern not apply. / inactivityCEP.select(new PatternSelectFunction() { @Override public Object select(Map pattern) throws Exception { System.out.println(pattern); return null; } }); / >> What am I missing you missing output ;) 2017-01-07 22:47 GMT+04:00 madhairsilence : > Anybody?. Got kinda stuck here :( > > > > -- > View this message in context: http://apache-flink-mailing- > list-archive.1008284.n3.nabble.com/DataStream-and-CEP- > Pattern-not-matching-after-applying-a-window-tp15164p15173.html > Sent from the Apache Flink Mailing List archive. mailing list archive at > Nabble.com. > --001a114fdd18df06db0545a26a17--