Re:Re: Join two data streams on a given key and diffrent common window size.

2018-05-12 Thread lehaxing
thanks a lot ,I'm sorry to recover so late,I will pay attention to this. At 2018-04-23 19:03:11, "Fabian Hueske" wrote: Hi, The semantics of the joins offered by the DataStream API in Flink 1.4 and before as well as the upcoming 1.5 version are a bit messed up, IMO.

Re: Join two data streams on a given key and diffrent common window size.

2018-04-23 Thread Fabian Hueske
Hi, The semantics of the joins offered by the DataStream API in Flink 1.4 and before as well as the upcoming 1.5 version are a bit messed up, IMO. Since Flink 1.4, Flink SQL implements a better windowed join [1]. DataStream and SQL can be easily integrated with each other. A similar

Join two data streams on a given key and diffrent common window size.

2018-04-22 Thread lehaxing
hi all, flink 1.4 or 1.5 only support Join two data streams as shown below: but i have two data streams A and B, i want make A and B each set its own window size, not a common size; if can do this ,i can join A (window size:1min , TumblingEventTimeWindow) and B (window