Hi, My ultimate requirement is to stop processing of certain events between 00:00:00 and 01:00:00 for each day (Time is in HH:mm:SS format).
I am flink newbie and I thought only option to delay elements is to collect them in a window between 00:00:00 and 01:00:00 for each day. TumblingEventTimeWindows for one hour seems the possible candidate but as I understand this window will be present for all times, i.e (startTime, startTime+1hour), (startTime+1hour, startTime+2hour), (startTime+2hour, startTime+3hour)... How will it be possible to start a window at 00:00:00 each day and stop the window at 01:00:00? Or is there any other option to keep elements in the job between 00:00:00 and 01:00:00 and then start to process them after 01:00:00? Best regards -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
