-
Notifications
You must be signed in to change notification settings - Fork 14k
Pull requests: apache/flink
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-40435][python] Add explode support to DataFrame API
#29196
opened Sep 15, 2026 by
beetle0915
Contributor
•
Draft
1 task done
[FLINK-40666][table] Simplify SNAPSHOT function by removing load_completed_condition argument
#29195
opened Sep 15, 2026 by
fhueske
Contributor
Loading…
1 task done
[FLINK-40675][sql-gateway] Fix unstable SqlGatewayServiceITCase#testReleaseLockWhenFailedToSubmitOperation
#29194
opened Sep 15, 2026 by
SEPURI-SAI-KRISHNA
Contributor
Loading…
1 task done
[FLINK-40674][runtime] Stop deserializing SerializedThrowable via ObjectInputStream on parse
#29193
opened Sep 15, 2026 by
gaborgsomogyi
Contributor
Loading…
1 task done
[FLINK-40528][table-planner] Address additional feedback for partial-delete StreamExecCalc
#29192
opened Sep 15, 2026 by
twalthr
Contributor
Loading…
1 task done
[FLINK-40671][network] Document why UnknownInputChannel graduation hardcodes needsRecovery=false
#29191
opened Sep 15, 2026 by
1996fanrui
Member
Loading…
[FLINK-40668][network] Document why the recovery drain cannot stall on zero-credit needsRecovery channels
#29190
opened Sep 15, 2026 by
1996fanrui
Member
Loading…
[FLINK-40667][network] Fix buffer ref-count leak in recovery channel-state filtering
#29189
opened Sep 15, 2026 by
1996fanrui
Member
Loading…
[BP-1.20][FLINK-39105][rest] Fix RestClientTest.testConnectionTimeout to handle environment-dependent exception types
#29187
opened Sep 15, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[FLINK-40655][runtime] Fix flaky partition release test
#29183
opened Sep 15, 2026 by
qiuyanjun888
Loading…
1 task done
[FLINK-40660][connector-base] Retry the shutdown synchronization put in SplitFetcher
#29182
opened Sep 14, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[FLINK-40641][metrics] Cover the Prometheus reporter exposition contract
#29178
opened Sep 14, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[FLINK-32649][metrics] Do not report a metric whose variables differ from an earlier metric of the same name
#29172
opened Sep 14, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[FLINK-40648][metrics] Do not report a metric whose variables collide into one label name
#29171
opened Sep 14, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[FLINK-40645][state/forst] Unregister closed streams from FileCacheEntry#openedStreams
#29169
opened Sep 14, 2026 by
seungjoo-choi-bucketplace
Loading…
[FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed
#29168
opened Sep 14, 2026 by
seungjoo-choi-bucketplace
Loading…
[FLINK-40639][kubernetes] Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default
#29167
opened Sep 13, 2026 by
SEPURI-SAI-KRISHNA
Contributor
Loading…
1 task done
[FLINK-40637][table] Expand catalog views hermetically against the view's own database
#29165
opened Sep 12, 2026 by
talatuyarer
Loading…
[FLINK-40418][python] Support attribute-based column access on DataFrame
#29164
opened Sep 12, 2026 by
beetle0915
Contributor
Loading…
1 task done
[FLINK-40632][s3] Annotate native-s3-fs to PublicEvolving
#29159
opened Sep 11, 2026 by
Samrat002
Contributor
Loading…
1 task
[FLINK-40638][historyserver] Add optional custom URL handlers for JobManager and TaskManager logs in the history server
#29157
opened Sep 10, 2026 by
argoyal2212
Contributor
Loading…
[FLINK-40354][state/forst] Configure the TTL compaction filter for State V2 states
community-reviewed
PR has been reviewed by the community.
#29149
opened Sep 9, 2026 by
seungjoo-choi-bucketplace
Loading…
[FLINK-40598][docs] Synchronize Chinese Elastic Scaling documentation
#29147
opened Sep 9, 2026 by
Jackeyzhe
Contributor
Loading…
[FLINK-40576][fs] Drop stale dependencies from flink-s3-fs-presto NOTICE
#29145
opened Sep 9, 2026 by
spuru9
Contributor
Loading…
1 task done
Previous Next
ProTip!
Follow long discussions with comments:>50.