Hi,You are correct that with sliding windows you will have 3600 “open windows” at any point.Could you describe a bit more what you want to do?If you simply want to have an update of something like a counter every second, then you canimplement your own logic with a ProcessFunction that allows to handle state and timers in acustom way (see ).Hope this helps,Kostas https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/stream/operators/process_function.htmlOn Jul 5, 2018, at 12:12 PM, YennieChen88 <chenyanying3@xxxxxx> wrote:Hi，
I want to use slide windows of 1 hour window size and 1 second step
size. I found that once a element arrives, it will be processed in 3600
windows serially through one thread. It takes serveral seconds to finish one
element processing，much more than my expection. Do I have any way to
Thank you very much for your reply.
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/