Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 7337419160 for ; Thu, 7 Apr 2016 06:22:02 +0000 (UTC) Received: (qmail 51748 invoked by uid 500); 7 Apr 2016 06:22:02 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 51653 invoked by uid 500); 7 Apr 2016 06:22:02 -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 51643 invoked by uid 99); 7 Apr 2016 06:22:01 -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, 07 Apr 2016 06:22:01 +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 6BA2F180114 for ; Thu, 7 Apr 2016 06:22:01 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.313 X-Spam-Level: ** X-Spam-Status: No, score=2.313 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_NONE=-0.0001, URI_HEX=1.313] autolearn=disabled Received: from mx2-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 DAhmsWe9z3My for ; Thu, 7 Apr 2016 06:21:59 +0000 (UTC) Received: from mwork.nabble.com (mwork.nabble.com [162.253.133.43]) by mx2-lw-us.apache.org (ASF Mail Server at mx2-lw-us.apache.org) with ESMTP id 45D245F39C for ; Thu, 7 Apr 2016 06:21:59 +0000 (UTC) Received: from mjoe.nabble.com (unknown [162.253.133.57]) by mwork.nabble.com (Postfix) with ESMTP id D078021B73F04 for ; Wed, 6 Apr 2016 23:08:34 -0700 (PDT) Date: Wed, 6 Apr 2016 22:50:44 -0700 (PDT) From: norman sp To: user@flink.apache.org Message-ID: <1460008244616-5976.post@n4.nabble.com> In-Reply-To: <1459933479738-5948.post@n4.nabble.com> References: <1459933479738-5948.post@n4.nabble.com> Subject: Re: Flink CEP AbstractCEPPatternOperator fail after event detection MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit Hi Till, I used Flink version 1.0.0 and tried all three TimeCharacteristics. Not I tried the new Flink 1.0.1 that gives me the following error. After detecting an event it processes a few stream tuples but then crashes. I'm not sure how to solve that part of the error message: "This can indicate that the element belonging to the previous relation has been already pruned, even though you expect it to be still there" 4> ####### Warning! FlowPatternEvent: ####### 4> (7605e43c-ca20-4524-af5f-23fd8e55d7b9,Intensity - Value,25.0,3.0,75.0) 4> (5025ef64-2b83-4112-b9bd-2d7de46454c9,Pressure - Value,7.0,3.0,21.0) 4> (3d501c5b-b0e2-41e6-bfdc-14c996df6e19,Flow - Value,27.0,3.0,81.0) 04/06/2016 16:41:31 Map -> Sink: Unnamed(4/4) switched to CANCELED 04/06/2016 16:41:31 AbstractCEPPatternOperator(1/1) switched to FAILED java.lang.RuntimeException: Failure happened in filter function. at org.apache.flink.cep.nfa.NFA.computeNextStates(NFA.java:292) at org.apache.flink.cep.nfa.NFA.process(NFA.java:136) at org.apache.flink.cep.operator.AbstractCEPPatternOperator.processEvent(AbstractCEPPatternOperator.java:93) at org.apache.flink.cep.operator.CEPPatternOperator.processWatermark(CEPPatternOperator.java:88) at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:158) at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:225) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) at java.lang.Thread.run(Thread.java:745) Caused by: java.lang.IllegalStateException: Could not find previous shared buffer entry with key: State(start, Normal, [ StateTransition(TAKE, FlowOver10, with filter), StateTransition(IGNORE, start), ]), value: (83788338-b26c-4538-a437-77d1bbf7b348,Pressure - Value,7.0,5.0,35.0) and timestamp: 1459953675999. This can indicate that the element belonging to the previous relation has been already pruned, even though you expect it to be still there. at org.apache.flink.cep.nfa.SharedBuffer.put(SharedBuffer.java:104) at org.apache.flink.cep.nfa.NFA.computeNextStates(NFA.java:269) ... 8 more -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-AbstractCEPPatternOperator-fail-after-event-detection-tp5948p5976.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.