-
Notifications
You must be signed in to change notification settings - Fork 13.9k
Pull requests: apache/flink
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst
#28261
opened May 26, 2026 by
spuru9
Contributor
Loading…
1 task done
[FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs
target:release-2.3
#28259
opened May 26, 2026 by
lincoln-lil
Contributor
Loading…
[FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs
target:release-1.20
#28258
opened May 26, 2026 by
lincoln-lil
Contributor
Loading…
[FLINK-39763][table] Allow inferring constants with
IS NOT DISTINCT FROM
#28256
opened May 26, 2026 by
snuyanzin
Contributor
Loading…
1 task
[FLINK-39754][core] Fix int overflow in DataOutputSerializer.resize
#28252
opened May 25, 2026 by
sauliusvl
Loading…
1 task done
[FLINK-39753][state/rocksdb] Close ColumnFamilyOptions from getDescriptor() in Compactor
community-reviewed
PR has been reviewed by the community.
#28251
opened May 25, 2026 by
leekeiabstraction
Loading…
[FLINK-39751][tests] Add PR has been reviewed by the community.
FailsOnJava25
community-reviewed
#28249
opened May 25, 2026 by
snuyanzin
Contributor
Loading…
1 task
[FLINK-36298][table] Fix NullPointerException in metadata query supplier on fresh threads
#28247
opened May 25, 2026 by
Au-Miner
Contributor
Loading…
[FLINK-36472][table] Preserve right-side projections when converting Correlate to physical
#28246
opened May 25, 2026 by
Au-Miner
Contributor
Loading…
[FLINK-39735][table] Expose input upsert key on TableSemantics for PTFs
community-reviewed
PR has been reviewed by the community.
#28241
opened May 23, 2026 by
jubins
Loading…
1 task done
[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
[FLINK-37912][Python] Add generic typing to DataStream interfaces
#28239
opened May 23, 2026 by
Vaibhav-S-Gowda
Loading…
[FLINK-39636][table] Add produces_full_deletes parameter in TO_CHANGELOG
#28235
opened May 22, 2026 by
raminqaf
Contributor
Loading…
1 task done
[FLINK-39719][table] Drop late probe records from TemporalRowTimeJoinOperator
#28229
opened May 22, 2026 by
fhueske
Contributor
Loading…
1 task done
[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
[FLINK-38705][models] Add sync OpenAI model provider
#28223
opened May 21, 2026 by
lihaosky
Contributor
Loading…
[FLINK-39726][table] Support USING CONNECTION clause in CREATE TABLE
#28222
opened May 21, 2026 by
lihaosky
Contributor
Loading…
[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…
[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…
[FLINK-39715] [table-planner] Fix IndexOutOfBoundsException in FlinkExpandConversionRule for global aggregate after sort
#28218
opened May 21, 2026 by
arvindKandpal-ksolves
Contributor
Loading…
1 task
[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
[FLINK-37422][docs] Fix typos and translation alignment in streaming analytics zh document
#28215
opened May 20, 2026 by
arvindKandpal-ksolves
Contributor
Loading…
1 task done
[FLINK-39379][table] Add state management to PTF test harness
#28212
opened May 20, 2026 by
autophagy
Contributor
Loading…
1 task done
[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
Previous Next
ProTip!
Find all pull requests that aren't related to any open issues with -linked:issue.