-
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-6417][connector/filesystem] Support glob paths in FileSource
#29219
opened Sep 17, 2026 by
Cribbee
Loading…
1 task done
[FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue
#29218
opened Sep 16, 2026 by
SAlexandru
Loading…
1 task done
[FLINK-40684][model] Fix tensor name case in Triton models.
#29217
opened Sep 16, 2026 by
damjad
Contributor
Loading…
1 task done
[FLINK-40180] Non-keyed/operator state support in State Catalog
#29216
opened Sep 16, 2026 by
gyfora
Contributor
Loading…
1 task done
[BP-1.20][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs
community-reviewed
PR has been reviewed by the community.
target:release-1.20
#29215
opened Sep 16, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[BP-2.2][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs
community-reviewed
PR has been reviewed by the community.
target:release-2.2
#29214
opened Sep 16, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[BP-2.3][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs
community-reviewed
PR has been reviewed by the community.
target:release-2.3
#29213
opened Sep 16, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[FLINK-40472][python] Support Arrow vectorized UDFs in DataFrame API
#29210
opened Sep 16, 2026 by
auroflow
Contributor
Loading…
1 task done
[FLINK-40584][state/rocksdb] Bound MapState and timer prefix iterators
#29209
opened Sep 16, 2026 by
Savonitar
Contributor
Loading…
1 task done
[FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest
#29208
opened Sep 16, 2026 by
SEPURI-SAI-KRISHNA
Contributor
Loading…
1 task done
[FLINK-40681][table] Reproducer: streaming outer join drops the null-padded row after an inner-side update followed by delete
#29204
opened Sep 16, 2026 by
MartijnVisser
Contributor
•
Draft
1 task done
[FLINK-40672][table] Preserve nullability when casting VARIANT values
#29202
opened Sep 16, 2026 by
dylanhz
Contributor
Loading…
1 task done
[FLINK-40419][python] Add regular join support to DataFrame API
#29201
opened Sep 16, 2026 by
SulphurFH
Loading…
1 task done
[FLINK-36808][table-planner] Include pushed-down source abilities in the lookup join digest
#29200
opened Sep 15, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[FLINK-40435][python] Add explode support to DataFrame API
#29196
opened Sep 15, 2026 by
beetle0915
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-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…
[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
community-reviewed
PR has been reviewed by the community.
#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…
Previous Next
ProTip!
Find all pull requests that aren't related to any open issues with -linked:issue.