Hi Yashwant Ganti,
> Caused by: java.io.InvalidClassException: com..**.***; local
> class incompatible: stream classdesc serialVersionUID = -7317586767482317266,
> local class serialVersionUID = -8797204481428423223
1. Please try this way: find the com..**.***, add `priva
Hi Lian Jiang,
Both two solutions have its advantage and disadvantages.
Solution 1:
advantage:
1. Code is simple. The multiple join operator decides that join
sequence, which means the only (A,B) could output the streamA_B_C and
only (A,B,C) could output the streamA_B_C_D. BTW, this is
er, for this to happen the channel must consistently generate
> watermarks smaller than watermarks from ALL aligned channels (and its
> elements must have a smaller timestamp). I'm not sure how likely it
> is. Is it something you see in production?
>
> Regards,
> Roman
>
&g
Hi community,
Now after a channel become active from idle, the watermark on this
channel would not be took into account when align watermarks util it
generates a watermark equals to or bigger than last emitted watermark.
It makes sense because it could prevent the newly active task resumed
from idl
Hi Mans,
+1 for Austin's reply.
I would like to add something about "allow lateness".
After introduce Windowing table-valued function in Flink 1.13,
User could use two SQL solution to do window aggregate. And 'allow
lateness' behavior is different in these two solutions.
1. If ad
