Skip to content

Pull requests: apache/flink

New pull request New
942 Open 25,417 Closed
942 Open 25,417 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[FLINK-37547][docs] Document PTFs component=Documentation
#26375 opened Mar 28, 2025 by twalthr Loading…
5
[FLINK-37582] Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram component=TableSQL/Planner
#26374 opened Mar 28, 2025 by dawidwys Loading…
8
[FLINK-37581] Avoid duplicate calculation for total Flink memory component=Runtime/Configuration
#26373 opened Mar 28, 2025 by beliefer Loading…
2
[hotfix] Avoid copy Set for variable implementedRpcGateways
#26372 opened Mar 28, 2025 by beliefer Loading…
2
[FLINK-37579] Avoid duplicate generate ResourceProfile component=Runtime/Configuration
#26371 opened Mar 28, 2025 by beliefer Loading…
1
[BP-2.0][FLINK-37576][runtime] Fix the incorrect status of the isBroadcast field in AllToAllBlockingResultInfo when submitting a job graph. component=Runtime/Coordination
#26370 opened Mar 28, 2025 by JunRuiLee Loading…
2
[FLINK-37576][runtime] Fix the incorrect status of the isBroadcast field in AllToAllBlockingResultInfo when submitting a job graph. component=Runtime/Coordination
#26369 opened Mar 28, 2025 by JunRuiLee Loading…
3
[FLINK-37575] Simplify the code for creating Netty shuffle environment. component=Runtime/Network
#26368 opened Mar 28, 2025 by beliefer Loading…
2
[hotfix] Avoid duplicate fetch the size of memory segment
#26367 opened Mar 28, 2025 by beliefer Loading…
2
[hotfix] [docs] Fix flink-connector-kafka version in "How to use Maven.." doc of Flink master
#26366 opened Mar 27, 2025 by Prashant15887 • Draft
1
[FLINK-37569] Add userKeySerializer in RegisteredKeyValueStateBackend V2 component=Runtime/Checkpointing
#26364 opened Mar 27, 2025 by mayuehappy Loading…
6
[hotfix] Simplify the calling on addShutdownHook
#26363 opened Mar 27, 2025 by beliefer Loading…
4
[hotfix] Rename prefix to tag for FileChannelManagerImpl
#26362 opened Mar 27, 2025 by beliefer Loading…
4
[FLINK-37540][table-planner] Introduce SupportsTargetColumnWriting sink ability component=TableSQL/API
#26361 opened Mar 27, 2025 by xiangyuf Loading…
4
Add an example to use PTF
#26358 opened Mar 27, 2025 by fsk119 • Draft
1
[FLINK-37546] Use DefaultInstantiatorStrategy for FlinkScalaKryoInstantiator component=API/TypeSerializationSystem
#26357 opened Mar 26, 2025 by mxm Loading…
2
[FLINK-37570][metrics] Export default watermark if split doesn't have any component=Runtime/Metrics
#26356 opened Mar 26, 2025 by Efrat19 Loading…
6
[hotfix][docs] update create table syntax pseudo code
#26355 opened Mar 26, 2025 by Laffery Loading…
5
[FLINK-36443][table][test][bp-2.0] Improve flaky tests related to partition specs component=TableSQL/Planner
#26354 opened Mar 26, 2025 by morazow Loading…
2
[FLINK-37558] Check right variable in addSpan component=<none>
#26353 opened Mar 26, 2025 by chanhyeong Loading…
3
Added Confluent to Vendor Solutions section
#26346 opened Mar 25, 2025 by pmoskovi Loading…
2
[FLINK-37549][table][docs]: Fix some scala and markdown syntax errors in tableApi page component=Documentation
#26341 opened Mar 25, 2025 by CuiYanxiang Loading…
6
[FLINK-37544] Replace Timer with single thread scheduled executor for BlobServer component=Runtime/REST
#26339 opened Mar 24, 2025 by beliefer Loading…
5
[hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety
#26332 opened Mar 20, 2025 by bjornarjatten Loading…
3
[FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… component=Runtime/Checkpointing
#26330 opened Mar 20, 2025 by hejufang Loading…
4
ProTip! Add no:assignee to see everything that’s not assigned.