Hello,
For your first question:
> the number of tuples are same in both cases
I guess you mean the total number of tuples here, right? So this means
that you have fewer, but larger windows. Suppose that you have W
windows, each with S tuples. Then your total input has W * S tuples,
and your tota
Hi,
I am experiencing strange flink stream windowed join behavior.
I want to do windowed (processing time) join between two partitioned
streams. I read data from socket.
I have two cases: 1. data speed in socket is relatively slow (say 1K ps)
2. data speed in socket is high (say 37K).
The number
