Skip to content

Pull requests: apache/flink

New pull request New
225 Open 27,104 Closed
225 Open 27,104 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[FLINK-38804][runtime] draft fix 3.3
#27375 opened Jan 1, 2026 by Efrat19 • Draft
1
[FLINK-38826][table] Add new ArgumentStrategy to support array with specified element type
#27374 opened Dec 31, 2025 by dylanhz Loading…
2
[FLINK-38804][runtime] draft fix
#27373 opened Dec 30, 2025 by Efrat19 • Draft
1
[FLINK-38753] Enrich upsert keys by equi-join equivalences
#27372 opened Dec 30, 2025 by fresh-borzoni Loading…
1
[FLINK-38579] Fix incorrect UB drop for filter on non-upsert key
#27371 opened Dec 29, 2025 by fresh-borzoni Loading…
3
[FLINK-38819] Add debug logs for serialisation errors community-reviewed PR has been reviewed by the community.
#27370 opened Dec 29, 2025 by vsantwana Loading…
18
[FLINK-38841][table] Enforce expected nullability in FamilyArgumentStrategy community-reviewed PR has been reviewed by the community.
#27369 opened Dec 26, 2025 by dylanhz Loading…
3
[FLINK-38523] Update Pekko to 1.4.0
#27368 opened Dec 26, 2025 by mateczagany • Draft
17
[FLINK-38763][runtime] Add REST API for JarRunApplication
#27367 opened Dec 24, 2025 by eemario Loading…
1
[hotfix] [docs] Update overview.md with link to dependencies community-reviewed PR has been reviewed by the community. target:release-1.14
#27366 opened Dec 23, 2025 by ZDevelop94 Loading…
3
[FLINK-38762][runtime] Introduce SingleJobApplication
#27362 opened Dec 23, 2025 by eemario Loading…
7
[FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction
#27361 opened Dec 22, 2025 by featzhang Loading…
1
[FLINK-38825][table] Add SQL/Table API integration for AsyncBatch inference
#27360 opened Dec 22, 2025 by featzhang Loading…
1
[FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator
#27359 opened Dec 22, 2025 by featzhang Loading…
1
[FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator
#27358 opened Dec 21, 2025 by featzhang Loading…
1
[FLINK-38825][streaming] Add ordered async batch support for AsyncBatchWaitOperator
#27357 opened Dec 21, 2025 by featzhang Loading…
1
[FLINK-38825] Add time-based batch triggering for AsyncBatchWaitOperator
#27356 opened Dec 21, 2025 by featzhang Loading…
4 tasks done
1
[FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator
#27355 opened Dec 21, 2025 by featzhang Loading…
1
[FLINK-38189][core][python] Add RowFieldExtractorSchema for Row field serialization
#27353 opened Dec 20, 2025 by Nflrijal Loading…
1
[FLINK-38822] Extend URL_DECODE with optional recursive decoding
#27351 opened Dec 19, 2025 by featzhang Loading…
1
[FLINK-38820] Move ptf rule to rule folder
#27349 opened Dec 18, 2025 by lihaosky Loading…
3
[hotfix][metrics] Fix NullArgumentException when calculating checkpoint statistics with empty data community-reviewed PR has been reviewed by the community.
#27348 opened Dec 18, 2025 by qiref Loading…
3
[FLINK-38810] Use splittable timers in Interval Join
#27345 opened Dec 15, 2025 by rkhachatryan • Draft
2
[FLINK-38809][Tests] Upgrade Testcontainers to 2.0.3
#27341 opened Dec 15, 2025 by MartijnVisser • Draft
6
[FLINK-38807][state] Add state SQL metadata based type inference community-reviewed PR has been reviewed by the community.
#27340 opened Dec 12, 2025 by gaborgsomogyi Loading…
6
ProTip! Follow long discussions with comments:>50.