[FLINK-29183] flink job ended before window time up while using bounded stream source

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.15.2
• Component/s: API / DataStream
• Assignee: Unassigned
• Reporter: Lu
• Created: 02/Sep/22 07:45
• Updated: 20/Oct/22 10:57
• Resolved: 20/Oct/22 10:57

Description

 

when i use a long time window while using bounded stream in STREAMING mode，the job shutdown before the window has been triggered and then i have nothing to print.

if i use BATCH mode with the same code,  it will work. But the batch shuffle is so expensive so i still prefer STREAMING. 

Is there any method could fix this problem? Or should i have mistake in my code?

Looking forward to your reply.  Thanks in advance.

Issue Links

• Blocked: FLINK-18647 How to handle processing time timers with bounded input
• is caused by: FLINK-18647 How to handle processing time timers with bounded input