Hi Benchao,
Thanks for the input.
The code is self-explanatory.
Best,
Dongwon
On Thu, Dec 10, 2020 at 12:20 PM Benchao Li wrote:
> Hi Dongwon,
>
> I think you understand it correctly.
> You can find this logic here[1]
>
> [1]
> https://github.com/apache/flink/blob/master/flink-streaming-jav
Hi Dongwon,
I think you understand it correctly.
You can find this logic here[1]
[1]
https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/StatusWatermarkValve.java#L108
Dongwon Kim 于2020年12月10日周四 上午12:21写道:
> Hi,
>
> Let