Hi Norman,
sorry for the late reply. I finally found time and could, thanks to you,
reproduce the problem. The problem was that the window borders were treated
differently in two parts of the code. Now the left border of a window is
inclusive and the right border (late elements) is exclusive. I've
Hi,
here is an example input that produces the error. These are read from Kafka.
01:43:43.5921 2121{"Pressure target - Value":"6"}
01:43:43.5961 2121{"Flow target - Value":"23"}
01:43:44.2631 2121{"Pressure target - Value":"7"}
01:43:44.9721 2121
Hi Norman,
could you provide me an example input data set which produces the error?
E.g. the list of strings you inserted into Kafka/read from Kafka?
Cheers,
Till
On Thu, Apr 7, 2016 at 11:05 AM, norman sp wrote:
> Hi Till,
> thank you. here's the code:
>
> public class CepStorzSimulator {
>
>
Hi Till,
thank you. here's the code:
public class CepStorzSimulator {
public static void main(String[] args) throws Exception {
final ParameterTool parameterTool =
ParameterTool.fromArgs(args);
if(parameter
Hi Norman,
this error is exactly what I thought I had fixed. I guess there is still
another case where a premature pruning can happen in the SharedBuffer.
Could you maybe send me the example code with which you could produce the
error. The input data would also be very helpful. Then I can debug it
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
t
Hi Norman,
which version of Flink are you using? We recently fixed some issues with
the CEP library which looked similar to your error message. The problem
occurred when using the CEP library with processing time. Switching to
event or ingestion time, solve the problem.
The fixes to make it also
