Skip to content

Pull requests: apache/flink

New pull request New
Clear current search query, filters, and sorts
1,191 Open 23,725 Closed
1,191 Open 23,725 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Milestones
Filter by milestone
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-34482][checkpoint] Rename checkpointing options component=Runtime/Checkpointing
#24878 opened Jun 3, 2024 by masteryhx Loading… updated Jun 13, 2024
8
[FLINK-35512[flink-clinets] Don't depend on the flink-clients jar actually existing.
#24931 opened Jun 13, 2024 by SamBarker Loading… updated Jun 13, 2024
[hotfix][checkpointing] Normalize file-merging sub dir
#24928 opened Jun 12, 2024 by zoltar9264 Loading… updated Jun 13, 2024
3
[FLINK-35157][runtime] Sources with watermark alignment get stuck once some subtasks finish component=Runtime/Coordination
#24757 opened May 6, 2024 by elon-X Loading… updated Jun 13, 2024
@1996fanrui
24
[FLINK-30400][docs] Add some notes about changes for flink-connector-base dependency in externalized connectors
#24930 opened Jun 13, 2024 by ruanhang1993 Loading… updated Jun 13, 2024
2
[FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: core component=API/Core
#24881 opened Jun 3, 2024 by GOODBOY008 Loading… updated Jun 13, 2024
@1996fanrui
33
[FLINK-35585] Add documentation for distribution
#24929 opened Jun 12, 2024 by jnh5y Loading… updated Jun 12, 2024
1
[FLINK-35378] [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction component=API/Core
#24805 opened May 16, 2024 by MartijnVisser Loading… updated Jun 12, 2024
10
[FLINK-34172] Add support for altering a distribution via ALTER TABLE component=<none>
#24886 opened Jun 4, 2024 by jnh5y Loading… updated Jun 12, 2024
25
[hotfix] Improve execution.checkpointing.unaligned.interruptible-timers.enabled documentation
#24926 opened Jun 12, 2024 by pnowojski Loading… updated Jun 12, 2024
1
[FLINK-35371][security] Add configuration for SSL keystore and truststore type component=Runtime/Network
#24919 opened Jun 10, 2024 by ammar-master Loading… updated Jun 12, 2024
@gaborgsomogyi
25
Update flink-operations-playground.md for a typo
#24927 opened Jun 12, 2024 by rohimsh Loading… updated Jun 12, 2024
1
[FLINK-35516][Connector/Files] Update the Experimental annotation for files connector component=Connectors/FileSystem
#24885 opened Jun 4, 2024 by RocMarshal • Draft updated Jun 12, 2024
@1996fanrui
1
[FLINK-35140][docs] Update Opensearch connector docs for 1.2.0 and 2.0.0 releases
#24921 opened Jun 11, 2024 by snuyanzin Loading… updated Jun 12, 2024
3
[FLINK-32091][checkpoint] Add file size metrics for file-merging
#24922 opened Jun 12, 2024 by fredia Loading… updated Jun 12, 2024
1
[FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function component=TableSQL/API
#24156 opened Jan 19, 2024 by jeyhunkarimov Loading… updated Jun 12, 2024
45
MailboxProcessor#processMailsWhenDefaultActionUnavailable avoids allocating Optional
#24923 opened Jun 12, 2024 by schlosna • Draft updated Jun 12, 2024
1
[FLINK-XXX][planner] Support custom shuffle for lookup join
#24920 opened Jun 10, 2024 by WencongLiu Loading… updated Jun 12, 2024
1
[FLINK-34487][ci] Adds Python Wheels nightly GHA workflow component=BuildSystem/CI
#24426 opened Mar 1, 2024 by morazow Loading… updated Jun 11, 2024
69
[FLINK-32562][connectors/filesystem] Handle compressed streams correctly in ConcatFileCompactor component=Connectors/FileSystem
#24914 opened Jun 7, 2024 by ferenc-csaky Loading… updated Jun 11, 2024
9
[FLINK-35543][HIVE] Upgrade Hive 2.3 connector to version 2.3.10 component=Connectors/Hive
#24905 opened Jun 6, 2024 by pan3793 Loading… updated Jun 11, 2024
9
[FLINK-35282][FLINK-35520] PyFlink Support for Apache Beam > 2.49 component=BuildSystem/CI
#24908 opened Jun 7, 2024 by snuyanzin Loading… updated Jun 11, 2024
4
[FLINK-35453][core] StreamReader Charset fix with UTF8 in core files component=<none>
#24842 opened May 26, 2024 by xuzifu666 Loading… updated Jun 11, 2024
4
[FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. component=TableSQL/API
#24773 opened May 12, 2024 by superdiaodiao Loading… updated Jun 11, 2024
63
[DRAFT][FLINK-33734] Merge unaligned checkpoint state handle component=Runtime/Checkpointing
#24247 opened Feb 2, 2024 by zoltar9264 Loading… updated Jun 11, 2024
2
ProTip! no:milestone will show everything without a milestone.