Hi Pankaj,
I think it should be in
org.apache.flink.runtime.io.network.api.writer.RecordWriter$OutputFlusher.
Best,
Yun
------------------------------------------------------------------
Sender:Pankaj Chand<pankajchanda...@gmail.com>
Date:2020/08/31 02:40:15
Recipient:user<user@flink.apache.org>
Theme:Implementation of setBufferTimeout(timeoutMillis)
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 (file and method) in the Flink source code are
the buffers being flushed by iteratively referring to the value of
timeoutMillis (or the default value), but have been unsuccessful. Please help.
Thanks,
Pankaj
