Re: Forking a stream with Flink

2019-01-31 Thread Daniel Krenn
I don't get what happened here. Did Selvaraj just hijack this question? Or what is going on? Am Di., 29. Jan. 2019 um 17:01 Uhr schrieb Selvaraj chennappan < selvarajchennap...@gmail.com>: > I think there is misunderstanding . I want to compare raw json and > transformed record . > Hence I need t

Forking a stream with Flink

2019-01-29 Thread Daniel Krenn
Hello Flink Community, Let's say I have multiple machines I get data from. I want to process the data of each machine seperately, but in the same way. Is it possible to "fork" a stream by some parameter and then processing the forks indepentently from each other, natively? Or do I need to do that

GlobalWindow with custom tigger doesn't work correctly

2019-01-22 Thread Daniel Krenn
Hello people! I have a DataStream, which has events with with a continuing number which signifies their belonging to a production cycle. In essence, this is what the data looks like: value, production cycle 12.0, 2000 12.3, 2000 one production cylce 12.2, 2000 0.0, 2001 0.4, 2002 another pro