-
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-40530][runtime-web] Isolate per-entry failures in job overview aggregation
#29062
opened Sep 1, 2026 by
argoyal2212
Contributor
Loading…
1 task done
[FLINK-40528][table] Make codegen tolerant to partial deletes
#29060
opened Aug 31, 2026 by
snuyanzin
Contributor
Loading…
1 task
[FLINK-40524][network] Skip the recoveredBuffers monitor on the getNextBuffer hot path for channels that never recover
#29058
opened Aug 31, 2026 by
1996fanrui
Member
Loading…
1 task
[FLINK-40521][network] Document potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery
#29057
opened Aug 31, 2026 by
1996fanrui
Member
Loading…
1 task
[FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery
#29056
opened Aug 31, 2026 by
1996fanrui
Member
Loading…
1 task
[FLINK-40518][checkpointing] Only enable checkpointing-during-recovery when unaligned checkpoints are enabled
#29055
opened Aug 31, 2026 by
1996fanrui
Member
Loading…
1 task
[FLINK-40522][network] Deduplicate RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel
#29054
opened Aug 31, 2026 by
1996fanrui
Member
Loading…
1 task
[FLINK-40525][network] Remove residual receivedBuffers lock in finishReadRecoveredState to avoid ABBA deadlock
#29053
opened Aug 31, 2026 by
1996fanrui
Member
Loading…
1 task
[FLINK-40523][network] Compute tracePersist debug string only when trace logging is enabled
#29052
opened Aug 31, 2026 by
1996fanrui
Member
Loading…
1 task
[FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives
community-reviewed
PR has been reviewed by the community.
#29050
opened Aug 31, 2026 by
manner
Contributor
Loading…
1 task done
[FLINK-39586][connector-base] Add watermark stall reproduction ITCase
#29049
opened Aug 31, 2026 by
MartijnVisser
Contributor
•
Draft
1 task done
[FLINK-39977][runtime] Recovery of merged channel state handles
#29043
opened Aug 29, 2026 by
Zakelly
Contributor
Loading…
1 task done
[FLINK-40497][table] Allow materialized tables to default to ON CONFLICT DO ERROR
community-reviewed
PR has been reviewed by the community.
#29040
opened Aug 28, 2026 by
gustavodemorais
Contributor
Loading…
1 task done
[FLINK-40503][core] Document effective idleness detection timing
community-reviewed
PR has been reviewed by the community.
#29039
opened Aug 28, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[FLINK-40505][runtime] Prune failed subtasks from watermark alignment
#29038
opened Aug 28, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain
#29037
opened Aug 28, 2026 by
MartijnVisser
Contributor
Loading…
1 task done
[FLINK-40197][python] Add sql() to the DataFrame API
#29036
opened Aug 28, 2026 by
fdolce
Loading…
1 task done
[FLINK-40422][python] Add slicing APIs to DataFrame API
#29033
opened Aug 28, 2026 by
Milesian111
Loading…
1 task done
[FLINK-40431][python] Add scalar UDF support to DataFrame API
#29029
opened Aug 27, 2026 by
auroflow
Contributor
Loading…
1 task done
Previous Next
ProTip!
Type g p on any issue or pull request to go back to the pull request listing page.