-
Notifications
You must be signed in to change notification settings - Fork 13.8k
Pull requests: apache/flink
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[DRAFT] [FLINK-24493] [flink-connector-base] Introduce DemultiplexingSink
#27072
opened Oct 1, 2025 by
rionmonster
•
Draft
[FLINK-38464] Introduce OrderedMultiSetState
community-reviewed
PR has been reviewed by the community.
#27071
opened Sep 30, 2025 by
rkhachatryan
Loading…
[DRAFT][FLINK-38461] Introduce SinkUpsertMaterializerV2
#27070
opened Sep 30, 2025 by
rkhachatryan
•
Draft
[FLINK-38460][tests] Improve test coverage for SinkUpsertMaterializer
#27068
opened Sep 30, 2025 by
rkhachatryan
Loading…
[FLINK-38369][runtime] Fix flaky RestClientTest
community-reviewed
PR has been reviewed by the community.
#27065
opened Sep 29, 2025 by
mateczagany
Loading…
[hotfix] Fix typos
community-reviewed
PR has been reviewed by the community.
#27062
opened Sep 29, 2025 by
zcoo
Loading…
[FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures
#27061
opened Sep 28, 2025 by
mateczagany
Loading…
[FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures
#27060
opened Sep 28, 2025 by
mateczagany
Loading…
[FLINK-34015] fix setting execution.savepoint.ignore-unclaimed-state …
community-reviewed
PR has been reviewed by the community.
#27058
opened Sep 28, 2025 by
xiangforever2014
Loading…
[FLINK-38272][runtime] Fix unstable BatchJobRecoveryTest
#27057
opened Sep 28, 2025 by
noorall
Loading…
FLINK-38449: Makes error message for fractional values for MemorySize explicit
community-reviewed
PR has been reviewed by the community.
#27056
opened Sep 27, 2025 by
navinvishy
Loading…
[FLINK-38468][flink-table-planner] When the coalesce parameter contains a function, convert it to case when
community-reviewed
PR has been reviewed by the community.
#27055
opened Sep 27, 2025 by
ChengJie1053
Loading…
[FLINK-38408][checkpoint] Complete the checkpoint CompletableFuture after updating statistics to ensures semantic correctness and prevent test failure
#27050
opened Sep 26, 2025 by
1996fanrui
Loading…
[FLINK-38418][python] Support pickling Instants when collecting TIMESTAMP_LTZ types in PyFlink
community-reviewed
PR has been reviewed by the community.
#27048
opened Sep 26, 2025 by
autophagy
Loading…
[BP-2.1][FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule
target:release-2.1
#27046
opened Sep 26, 2025 by
lincoln-lil
Loading…
[FLINK-38438][Runtime] Support session mini cluster when use local ex…
#27045
opened Sep 26, 2025 by
wwj6591812
Loading…
[hotfix] [docs] Fix Typo in Stateful Stream Processing introduction
community-reviewed
PR has been reviewed by the community.
target:release-1.13
#27044
opened Sep 26, 2025 by
Pactum7
Loading…
[docs] Typo fix
community-reviewed
PR has been reviewed by the community.
#27043
opened Sep 25, 2025 by
gunnarmorling
Loading…
[FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend
#27042
opened Sep 25, 2025 by
AlexYinHan
Loading…
[FLINK-38435][table] Refactor codegen and runner for MLPredict and Lo…
#27041
opened Sep 25, 2025 by
fsk119
Loading…
[FLINK-38424][planner] Support to parse VECTOR_SEARCH function
community-reviewed
PR has been reviewed by the community.
#27039
opened Sep 25, 2025 by
fsk119
Loading…
[FLINK-38432][python] Fix missing finish/reset for keyWriter/valueWriter in ArrowMapWriter
#27038
opened Sep 25, 2025 by
wzx140
Loading…
[FLINK-38423][table-api] Add VECTOR_SEARCH connector API
#27037
opened Sep 25, 2025 by
fsk119
Loading…
Previous Next
ProTip!
Updated in the last three days: updated:>2025-10-01.