Lu created FLINK-29183:
--------------------------
Summary: flink job ended before window time up while using bounded
stream source
Key: FLINK-29183
URL: https://issues.apache.org/jira/browse/FLINK-29183
Project: Flink
Issue Type: Bug
Components: API / DataStream
Affects Versions: 1.15.2
Reporter: Lu
Attachments: image-2022-09-02-15-33-08-459.png,
image-2022-09-02-15-35-18-590.png
!image-2022-09-02-15-35-18-590.png|width=574,height=306!
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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)