Thank you so much, Yun! It is exactly what I needed.
On Mon, Aug 31, 2020 at 1:50 AM Yun Gao wrote:
> Hi Pankaj,
>
> I think it should be in
> org.apache.flink.runtime.io.network.api.writer.RecordWriter$OutputFlusher.
>
> Best,
> Yun
>
>
>
> -
Hi Pankaj,
I think it should be in
org.apache.flink.runtime.io.network.api.writer.RecordWriter$OutputFlusher.
Best,
Yun
--
Sender:Pankaj Chand
Date:2020/08/31 02:40:15
Recipient:user
Theme:Implementation of setBufferTimeout(
Hello,
The documentation gives the following two sample lines for setting the
buffer timeout for the streaming environment or transformation.
*env.setBufferTimeout(timeoutMillis);env.generateSequence(1,10).map(new
MyMapper()).setBufferTimeout(timeoutMillis);*
I have been trying to find where (
