Re: Flink CEP AbstractCEPPatternOperator fail after event detection

2016-04-19 Thread Till Rohrmann
t;28"} > 01:44:01.6001 2121{"Pressure target - Value":"7"} > 01:44:01.6301 2121{"Flow target - Value":"28"} > 01:44:03.5871 2121{"Pressure target - Value":"7"} > 01:44:03.5911 2121{"Flow target - Value":"28"} > 01:44:06.1801 2121{"Pressure target - Value":"7"} > 01:44:06.2301 2121{"Flow target - Value":"28"} > > > Greetz Norman > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-AbstractCEPPatternOperator-fail-after-event-detection-tp5948p5996.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: Flink CEP AbstractCEPPatternOperator fail after event detection

2016-04-07 Thread norman sp
ot;:"7"} 01:44:01.6301 2121{"Flow target - Value":"28"} 01:44:03.5871 2121{"Pressure target - Value":"7"} 01:44:03.5911 2121{"Flow target - Value":"28"} 01:44:06.1801 2121{"Pressure target - Value":"7"} 01:44:06.2301 2121{"Flow target - Value":"28"} Greetz Norman -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-AbstractCEPPatternOperator-fail-after-event-detection-tp5948p5996.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Flink CEP AbstractCEPPatternOperator fail after event detection

2016-04-07 Thread Till Rohrmann
String[] split = a.split(":"); > String val = split[1]; > String testname = "test1"; > > String nom = val.replace("\"", > &qu

Re: Flink CEP AbstractCEPPatternOperator fail after event detection

2016-04-07 Thread norman sp
.toString(), testname, DeviceId, param, codedVal)); } } } } Example data looks like this: 1> 00:36:06.459 1 2121{"Pressure target - Value":"6", "Pressure target - Unit":"mmHg"} 1> 00:36:06.463 1 2121{"Flow target - Value":"23", "Flow target - Unit":"l/min"} -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-AbstractCEPPatternOperator-fail-after-event-detection-tp5948p5986.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Flink CEP AbstractCEPPatternOperator fail after event detection

2016-04-07 Thread Till Rohrmann
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

Re: Flink CEP AbstractCEPPatternOperator fail after event detection

2016-04-06 Thread norman sp
r-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.

Re: Flink CEP AbstractCEPPatternOperator fail after event detection

2016-04-06 Thread Till Rohrmann
FlowPattern ### > " + > pressure.toString() + " - " + flow.toString(); > } > } > > > How can I solve that? > Hope somebody could help me. > > greetz Norman > > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-AbstractCEPPatternOperator-fail-after-event-detection-tp5948.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Flink CEP AbstractCEPPatternOperator fail after event detection

2016-04-06 Thread norman sp
} How can I solve that? Hope somebody could help me. greetz Norman -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-AbstractCEPPatternOperator-fail-after-event-detection-tp5948.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.