Skip to content

Commit 85bdd4e

Browse files
Add: Tumbling window sink empty results explanation
Closes #246
1 parent 1c2f35a commit 85bdd4e

1 file changed

Lines changed: 8 additions & 0 deletions

File tree

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
---
2+
id: 29e617a947
3+
question: Why does the tumbling window job run successfully but the PostgreSQL sink
4+
table returns no rows when queried?
5+
sort_order: 31
6+
---
7+
8+
Flink streaming jobs emit results only after the window closes. With event-time processing and watermarks, the window will not close until the watermark passes the window end. If you query the PostgreSQL table too early, it may still be empty even though the job is running correctly. Let the job run for a short time so the watermark advances and the window results are written to the sink table.

0 commit comments

Comments
 (0)