We don't have a schedule for bugfix releases but do them based on need. AFAIK, a discussion about a 1.4.1 release has not been started yet.
Would you like to kick that off by sending a mail to the dev mailing list? 2018-01-12 16:41 GMT+01:00 Vishal Santoshi <vishal.santo...@gmail.com>: > Thanks. We will. > > When is 1.4.1 scheduled for release ? > > On Fri, Jan 12, 2018 at 3:24 AM, Dawid Wysakowicz < > wysakowicz.da...@gmail.com> wrote: > >> Hi Vishal, >> I think it might be due to this bug: https://issues.apache.org/jira >> /browse/FLINK-8226 >> It was merged for 1.4.1 and 1.5.0. Could you check with this changes >> applied? Would be really helpful. If the error still persists could you >> file a jira? >> >> Regards >> Dawid >> >> > On 11 Jan 2018, at 19:49, Vishal Santoshi <vishal.santo...@gmail.com> >> wrote: >> > >> > When checkpointing is turned on a simple CEP loop pattern >> > >> > private Pattern<Tuple2<Integer, SimpleBinaryEvent>, ?> alertPattern = >> Pattern.<Tuple2<Integer, SimpleBinaryEvent>>begin("star >> t").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 >> > >> >> >
