Skip to content

Pull requests: apache/flink

New pull request New
Clear current search query, filters, and sorts
1,214 Open 25,050 Closed
1,214 Open 25,050 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-37441] Rename factoryHierarchy to typeHierarchy for TypeExtractor component=API/Core
#26278 opened Mar 9, 2025 by beliefer updated Mar 9, 2025
4
[FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value. component=API/Core
#26277 opened Mar 9, 2025 by beliefer updated Mar 9, 2025
4
[FLINK-37439][state/forst] Support file override in wrapped file system component=Runtime/StateBackends
#26279 opened Mar 9, 2025 by Zakelly updated Mar 9, 2025
2
[BP-2.0][FLINK-37439][state/forst] Support file override in wrapped file system component=Runtime/StateBackends
#26280 opened Mar 9, 2025 by Zakelly updated Mar 9, 2025
1
[FLINK-37298] Added Pluggable Components for BatchStrategy & BufferWrapper in AsyncSinkWriter. component=Connectors/Common
#26274 opened Mar 8, 2025 by Poorvankbhatia updated Mar 9, 2025
1
[FLINK-37438] Improve the createLocalEnvironment by reduce duplicate operation on Configuration component=<none>
#26273 opened Mar 8, 2025 by beliefer updated Mar 9, 2025
3
[hotfix][tests] Use Junit5 import in FileSinkTest.
#26193 opened Feb 22, 2025 by slfan1989 updated Mar 9, 2025
8
[FLINK-37410][runtime/metrics] Split level Watermark metrics component=Runtime/Metrics
#26276 opened Mar 8, 2025 by Efrat19 • Draft updated Mar 9, 2025
1
[FLINK-37432][release] Add release note for release 2.0 component=ReleaseSystem
#26266 opened Mar 7, 2025 by reswqa • Approved updated Mar 8, 2025
39
[FLINK-37302][table] Support PTFs with time and timer services component=TableSQL/API component=TableSQL/Planner
#26250 opened Mar 5, 2025 by twalthr updated Mar 8, 2025
13
[FLINK-37431]We should use guava Lists instead of curator shade Lists… component=TableSQL/Planner
#26263 opened Mar 6, 2025 by zlzhang0122 updated Mar 8, 2025
3
[FLINK-37243] Adds main thread callback to AsyncWaitOperator component=<none>
#26122 opened Feb 7, 2025 by AlanConfluent updated Mar 7, 2025
9
[FLINK-36652] Upgrade Apache ORC Version to 1.9.4 component=Formats
#26265 opened Mar 7, 2025 by dyccode • Approved updated Mar 7, 2025
1
Bump io.netty:netty-common from 4.1.46.Final to 4.1.118.Final in /flink-end-to-end-tests/flink-end-to-end-tests-hive dependencies Pull requests that update a dependency file java Pull requests that update Java code
#26158 opened Feb 14, 2025 by dependabot bot updated Mar 7, 2025
9
[FLINK-37422][docs] Fix typo in streaming analytics zh document component=Documentation
#26249 opened Mar 5, 2025 by ranko-aha updated Mar 7, 2025
3
[hotfix][clients] Refactor PackagedProgram#getJobJarAndDependencies to reduce some redundant lines.
#26238 opened Mar 1, 2025 by RocMarshal updated Mar 6, 2025
2
[FLINK-37403] Convert interval join to regular join for updating source component=TableSQL/Planner
#26230 opened Feb 28, 2025 by bvarghese1 updated Mar 6, 2025
7
[FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire component=API/Python
#26229 opened Feb 28, 2025 by suez1224 updated Mar 6, 2025
2
[hotfix] make previousCpuTicks and previousProcCpuTicks volatile to increase visibility for all threads
#26257 opened Mar 5, 2025 by bjornarjatten updated Mar 6, 2025
3
[FLINK-37383][flink-examples]Correct throttling logic on ThrottledIterator component=Examples
#26203 opened Feb 24, 2025 by rafaelzimmermann updated Mar 6, 2025
7
[FLINK-37427] Fix incorrect NPE message in StandaloneHaServices constructor
#26258 opened Mar 6, 2025 by lurongjiang updated Mar 6, 2025
4
[FLINK-37408] Update all docker-compose references to docker compose component=<none>
#26239 opened Mar 2, 2025 by nilmadhab updated Mar 6, 2025
8
[FLINK-35014] SqlNode to operation conversion for models component=<none>
#25834 opened Dec 20, 2024 by lihaosky updated Mar 5, 2025
56
[FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese component=chinese-translation component=Documentation
#26196 opened Feb 23, 2025 by JinkunLiu updated Mar 5, 2025
14
[FLINK-37365][pyflink] Add API stability decorators for PyFlink APIs component=API/Python
#26247 opened Mar 4, 2025 by autophagy updated Mar 5, 2025
2
ProTip! Type g i on any issue or pull request to go back to the issue listing page.