← 返回首页
Pull requests · apache/flink · GitHub
Skip to content

Navigation Menu

Toggle navigation
Sign in
Appearance settings
Search or jump to...

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Include my email address so I can be contacted
Cancel Submit feedback

Saved searches

Use saved searches to filter your results more quickly

Cancel Create saved search
Appearance settings
Resetting focus

Pull requests: apache/flink

Labels 108 Milestones 0
New pull request New
369 Open 27,833 Closed
369 Open 27,833 Closed
Author
Filter by author
Loading
author:
Filter by this user
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
assignee:
Filter by this user
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[FLINK-36298][table] Fix NullPointerException in metadata query supplier on fresh threads
#28247 opened May 25, 2026 by Au-Miner Contributor Loading…
1
[FLINK-36472][table] Preserve right-side projections when converting Correlate to physical
#28246 opened May 25, 2026 by Au-Miner Contributor Loading…
1
[FLINK-39746][build] Add jdk25 profile in common_docker.sh
#28245 opened May 24, 2026 by snuyanzin Contributor Loading…
1 task
1
[hotfix][docs] Fix duplicate word typos in documentation community-reviewed PR has been reviewed by the community.
#28244 opened May 24, 2026 by jhanishant260 Loading…
3
[FLINK-39735][table] Expose input upsert key on TableSemantics for PTFs
#28241 opened May 23, 2026 by jubins Loading…
1 task done
1
[FLINK-39740][table-runtime] Do not regress highestSqnAndSizeState on row replace in LinkedMultiSetState community-reviewed PR has been reviewed by the community.
#28240 opened May 23, 2026 by jubins Loading…
1 task done
3
[FLINK-37912][Python] Add generic typing to DataStream interfaces
#28239 opened May 23, 2026 by Vaibhav-S-Gowda Loading…
1
[FLINK-39738] Use pekko ask() instead of tell() to ack the checkpoint community-reviewed PR has been reviewed by the community.
#28238 opened May 22, 2026 by rkhachatryan Contributor Loading…
9
[release-2.3][FLINK-39156][docs] Document ON CONFLICT community-reviewed PR has been reviewed by the community. target:release-2.3
#28237 opened May 22, 2026 by gustavodemorais Contributor Loading…
2
[FLINK-39737][s3] Switch to StandardRetryStrategy with configurable backoff for throttle-aware retry
#28236 opened May 22, 2026 by gaborgsomogyi Contributor Loading…
1 task done
5
[FLINK-39636][table] Add produces_full_deletes parameter in TO_CHANGELOG
#28235 opened May 22, 2026 by raminqaf Contributor • Draft
1 task done
4
[FLINK-39719][table] Drop late probe records from TemporalRowTimeJoinOperator
#28229 opened May 22, 2026 by fhueske Contributor Loading…
1 task done
1
[FLINK-39730][runtime] Honor maxExceptions on ApplicationExceptionsHandler community-reviewed PR has been reviewed by the community.
#28226 opened May 22, 2026 by jubins Loading…
1 task done
8
[FLINK-38705][models] Add sync OpenAI model provider
#28223 opened May 21, 2026 by lihaosky Contributor Loading…
1
[FLINK-39726][table] Support USING CONNECTION clause in CREATE TABLE
#28222 opened May 21, 2026 by lihaosky Contributor Loading…
6
[FLINK-36567][table] Honor io.tmp.dirs from flink-conf.yaml when extracting planner JAR
#28220 opened May 21, 2026 by Au-Miner Contributor Loading…
1
[FLINK-36561][table] Fix ResultSet.wasNull() not reflecting per-column null values in JDBC driver
#28219 opened May 21, 2026 by Au-Miner Contributor Loading…
1
[FLINK-39715] [table-planner] Fix IndexOutOfBoundsException in FlinkExpandConversionRule for global aggregate after sort
#28218 opened May 21, 2026 by arvindKandpal-ksolves Loading…
1 task
1
[FLINK-39741][python] Add type hints and fix docstrings in datastream/functions.py
#28216 opened May 20, 2026 by Vaibhav-S-Gowda Loading…
1 task done
5
[FLINK-37422][docs] Fix typos and translation alignment in streaming analytics zh document
#28215 opened May 20, 2026 by arvindKandpal-ksolves Loading…
1 task done
4
[FLINK-39379][table] Add state management to PTF test harness
#28212 opened May 20, 2026 by autophagy Contributor Loading…
1 task done
46
[Flink 39717][docs] Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE
#28211 opened May 20, 2026 by raminqaf Contributor Loading…
1 task done
3
[FLINK-39034][streaming] Fix timestamp loss in SortPartitionOperator
#28210 opened May 20, 2026 by Jackeyzhe Contributor Loading…
1 task
2
Bump idna from 3.11 to 3.15 in /flink-python/docs dependencies Pull requests that update a dependency file python:uv Pull requests that update python:uv code
#28203 opened May 19, 2026 by dependabot Bot Loading…
1
[FLINK-39711][runtime] Expose maxExceptions on exception message parameters community-reviewed PR has been reviewed by the community.
#28202 opened May 19, 2026 by jubins Loading…
1 task done
15
ProTip! Filter pull requests by the default branch with base:master.

Footer

© 2026 GitHub, Inc.