From dev-return-20993-archive-asf-public=cust-asf.ponee.io@flink.apache.org Mon Jan 15 11:49:35 2018 Return-Path: X-Original-To: archive-asf-public@eu.ponee.io Delivered-To: archive-asf-public@eu.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by mx-eu-01.ponee.io (Postfix) with ESMTP id 0420B180657 for ; Mon, 15 Jan 2018 11:49:35 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id E872B160C31; Mon, 15 Jan 2018 10:49:34 +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 3A423160C25 for ; Mon, 15 Jan 2018 11:49:34 +0100 (CET) Received: (qmail 87270 invoked by uid 500); 15 Jan 2018 10:49:33 -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 Delivered-To: moderator for dev@flink.apache.org Received: (qmail 82680 invoked by uid 99); 14 Jan 2018 17:27:40 -0000 X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.88 X-Spam-Level: * X-Spam-Status: No, score=1.88 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, KAM_SHORT=0.001, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:from:date:message-id:subject:to; bh=tSStbJmahDpx4zhB2e2xko1OUl+IMnEKbkmGdwEUI5E=; b=iV13o9ustAIBwADlOj+cVL5mJoSzdT2OllLrA0yTq2HJRDrs34jhz3YQoKoTTWmQPE F3g5FzoO6FMrdw93TbUFZR8oaY7WfGg4xcPdYL00sWl1dg742UEuxXdaXff0EX6NWEbj 3ketG3cQ2D55AkCTgcnhcSp2l+x4nCbG5cxu4B/aUiPkxwHqNCcJRMxjxgq3nGKa9BXr lpGYMNiNHgO46kaTL5wex6gQIMcUew6biN047Yx5zfQaSU2VVr/1NwV/qX7P7p8oFmo2 Ln36eOgIVf36OqLWmIWSBdXNxqXlml+pV1nAUNP6w39uqMDl5I6aCXl4bIGJDLYsnX9y J1ng== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=tSStbJmahDpx4zhB2e2xko1OUl+IMnEKbkmGdwEUI5E=; b=KmPrsPkU1DZVXjm6Gh6WzefRKNEKNZZuniJ/Clnlh0iTvLWl8oxp8qH55LQZH96u+E Svnd7hiYeBvDs2a9ETO9s5N8iGwB+NW2X5BpCFWLgnmArH/ki/iqy/11j5a91PfIUIIs 3hGS5oojORj/L1741ExvliiXiDI67fSqn8WRgWGRMRvwtWPpFGc82jTNCiVzRvwlNDty x2Cxg4Zeois/aBn9M41E2xxgb/rM26kbZN6Mv9SIjRfzl4+osoRL96BmqLrLdQoDCqYr dZ+ItZ60zJdVNaHoFfuDKVC03ENUN0BJPZSKrG1trH+qn0LaUd9BxmgEk3ZQuymqsUBn Bdqw== X-Gm-Message-State: AKwxytc7G2Y3vhsB11txJSernTUxSy4mPZtJY8UaNDkKeKjiiVcFCu1D eQdqI7HxLSEsYZmuxGYYNE30IPjk+byOuAUbPR9I9g== X-Google-Smtp-Source: ACJfBot6P4SZhZZWD4xL7eDbgCxqaGlNRbfpZ8IwR5B3vBoHfpWI67zQ2Q4a0Cf3Tg2ltRz98Cq3dJkDbh+9ve46Oew= X-Received: by 10.157.33.194 with SMTP id s60mr13485030otb.285.1515950850261; Sun, 14 Jan 2018 09:27:30 -0800 (PST) MIME-Version: 1.0 From: Vishal Santoshi Date: Sun, 14 Jan 2018 12:27:29 -0500 Message-ID: Subject: When is the scheduled release for 1.4.1 ? We have been waiting for a fix https://issues.apache.org/jira/browse/FLINK-8226 which looks a potential fix To: dev@flink.apache.org Content-Type: multipart/alternative; boundary="001a11494758ed47990562bfcff9" --001a11494758ed47990562bfcff9 Content-Type: text/plain; charset="UTF-8" This issues has a possible fix in 1.4.1. We have been waiting for a fix https://issues.apache.org/jira/browse/FLINK-8226 which looks a potential fix A simple CEP loop pattern private Pattern, ?> alertPattern = Pattern.>begin("start").where(checkStatusOn) .followedBy("middle").where(checkStatusOn).times(2) .next("end").where(checkStatusOn).within(Time.minutes(5)) I see failures. SimpleBinaryEvent is public class SimpleBinaryEvent implements Serializable { private int id; private int sequence; private boolean status; private long time; public SimpleBinaryEvent(int id, int sequence, boolean status , long time) { this.id = id; this.sequence = sequence; this.status = status; this.time = time; } public int getId() { return id; } public int getSequence() { return sequence; } public boolean isStatus() { return status; } public long getTime() { return time; } @Override public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; SimpleBinaryEvent that = (SimpleBinaryEvent) o; if (getId() != that.getId()) return false; if (isStatus() != that.isStatus()) return false; if (getSequence() != that.getSequence()) return false; return getTime() == that.getTime(); } @Override public int hashCode() { //return Objects.hash(getId(),isStatus(), getSequence(),getTime()); int result = getId(); result = 31 * result + (isStatus() ? 1 : 0); result = 31 * result + getSequence(); result = 31 * result + (int) (getTime() ^ (getTime() >>> 32)); return result; } @Override public String toString() { return "SimpleBinaryEvent{" + "id='" + id + '\'' + ", status=" + status + ", sequence=" + sequence + ", time=" + time + '}'; } } failure cause: Caused by: java.lang.Exception: Could not materialize checkpoint 2 for operator KeyedCEPPatternOperator -> Map (1/1). ... 6 more Caused by: java.util.concurrent.ExecutionException: java.lang.IllegalStateException: Could not find id for entry: SharedBufferEntry(ValueTimeWrapper((1,SimpleBinaryEvent{id='1', status=true, sequence=95, time=1505503380000}), 1505503380000, 0),.... I am sure I have the equals() and hashCode() implemented the way it should be. I have tried the Objects.hashCode too. In other instances I have had CircularReference ( and thus stackOverflow ) on SharedBuffer.toString(), which again points to issues with references ( equality and what not ). Without checkpointing turned on it works as expected. I am running on a local cluster. Is CEP production ready ? I am using 1.3.2 Flink --001a11494758ed47990562bfcff9--