Skip to content

Pull requests: apache/flink

New pull request New
438 Open 25,994 Closed
438 Open 25,994 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

[1.20][FLINK-37664][docs] Integrate Kudu connector docs
#26448 opened Apr 11, 2025 by ferenc-csaky Loading…
1
[1.19][FLINK-37664][docs] Integrate Kudu connector docs
#26447 opened Apr 11, 2025 by ferenc-csaky Loading…
1
[FLINK-37663] [connector-base] Address potential sync issue in FutureCompletingBlockingQueue wakeup component=API/Core
#26446 opened Apr 11, 2025 by herbherbherb Loading…
1
[FLINK-35458][test][type] Add serializer upgrade test for set serializer component=API/TypeSerializationSystem
#26445 opened Apr 11, 2025 by X-czh • Draft
1
[FLINK-37661] Remove Kryo serializer reference data from version 1.x component=API/TypeSerializationSystem
#26444 opened Apr 11, 2025 by X-czh Loading…
1
[FLINK-37660] Reenable Kryo serializer upgrade tests component=API/TypeSerializationSystem
#26443 opened Apr 11, 2025 by X-czh • Draft
1
[FLINK-37659][release] Generate reference data for state migration tests based on release-2.0.0 component=<none>
#26442 opened Apr 11, 2025 by X-czh Loading…
1
[FLINK-37655][runtime] Convert WindowStagger into an interface component=API/Core
#26441 opened Apr 11, 2025 by prashantbh Loading…
5
[FLINK-37554] Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend component=Runtime/StateBackends
#26440 opened Apr 11, 2025 by mayuehappy Loading…
13
[FLINK-37623][datastream] Async state support for process() in Datastream API component=<none>
#26439 opened Apr 11, 2025 by fredia Loading…
2
[FLINK-35466][table] Implement star expansion in function calls in SE… component=TableSQL/API component=TableSQL/Planner
#26438 opened Apr 10, 2025 by affo Loading…
3
[FLINK-37649][datagen] Datagen connector cannot set length for collection type component=Connectors/Common
#26437 opened Apr 10, 2025 by reswqa Loading…
5
[FLINK-37645] Improve existsUnboundedSource by avoiding duplicate check transformations component=<none>
#26434 opened Apr 10, 2025 by beliefer Loading…
2
[FLINK-37605][runtime] Infer checkpoint id on endInput in sink component=API/Core
#26433 opened Apr 9, 2025 by AHeise Loading…
4
[FLINK-35571][test] Can pass global test component=Tests
#26431 opened Apr 9, 2025 by gaopeng172 Loading…
1
[FLINK-37640][table-planner] Fix timestamp_ltz is converted timestamp in scan reuse component=TableSQL/Planner
#26430 opened Apr 9, 2025 by xishuaidelin Loading…
3
[FLINK-37638] Avoid duplicate call on getEffectiveConfiguration component=CommandLineClient
#26428 opened Apr 9, 2025 by beliefer Loading…
6
[hotfix] Rename loadJarFile to checkJarFile
#26427 opened Apr 9, 2025 by beliefer Loading…
5
[FLINK-37637] Avoid dead lock for Configuration's addAll component=API/Core
#26426 opened Apr 9, 2025 by beliefer Loading…
9
[hotfix] Remove the redundant config for execution target
#26425 opened Apr 9, 2025 by beliefer Loading…
3
[FLINK-37647] Add NonTimeRowsUnboundedPrecedingFunction for OverAggregate component=TableSQL/Planner component=TableSQL/Runtime
#26424 opened Apr 9, 2025 by bvarghese1 Loading…
15
[hotfix] Avoid duplicate loop for configuration
#26423 opened Apr 9, 2025 by beliefer Loading…
3
[FLINK-36158][FOLLOWUP] Replace the ZK HA path from jobgraphs to execution-plans component=Runtime/Coordination
#26420 opened Apr 8, 2025 by beliefer Loading…
2
[hotfix] Unify the name for the collection of SlotOffer with slotOffers
#26418 opened Apr 8, 2025 by beliefer Loading…
3
[hotfix] Rename registeredSlots to allocatedSlots
#26417 opened Apr 8, 2025 by beliefer Loading…
4
ProTip! Type g i on any issue or pull request to go back to the issue listing page.