Skip to content

Pull requests: apache/flink

New pull request New
Clear current search query, filters, and sorts
1,185 Open 23,741 Closed
1,185 Open 23,741 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-32086][checkpointing] Cleanup useless file-merging managed directory on exit of TM component=Runtime/Checkpointing component=Runtime/StateBackends
#24933 opened Jun 13, 2024 by zoltar9264 Loading… updated Jun 15, 2024
20
[FLINK-32562][connectors/filesystem] Handle compressed streams correctly in ConcatFileCompactor component=Connectors/FileSystem
#24914 opened Jun 7, 2024 by ferenc-csaky Loading… updated Jun 14, 2024
9
[FLINK-35619] Window rank query fails with 'must call validate first' component=TableSQL/Planner
#24940 opened Jun 14, 2024 by dawidwys Loading… updated Jun 14, 2024
7
[optimised][FLINK-34252][table] Fix lastRecordTime tracking in WatermarkAssignerOperator component=TableSQL/Runtime
#24941 opened Jun 14, 2024 by pnowojski Loading… updated Jun 14, 2024
1
[FLINK-35585] Add documentation for distribution component=<none>
#24929 opened Jun 12, 2024 by jnh5y Loading… updated Jun 14, 2024
7
[FLINK-25537] [JUnit5 Migration] Module: flink-core component=API/Core
#24939 opened Jun 14, 2024 by GOODBOY008 Loading… updated Jun 14, 2024
2
[FLINK-35598][sql-parser] Fix error comparison type ExtendedSqlRowTypeNameSpec#equalsDeep component=TableSQL/LegacyPlanner
#24937 opened Jun 14, 2024 by wzx140 Loading… updated Jun 14, 2024
5
[FLINK-20398][e2e] Migrate test_batch_sql.sh to Java e2e tests framework component=TableSQL/API component=Tests
#24471 opened Mar 8, 2024 by affo Loading… updated Jun 14, 2024
69
Flink 33386 review splited commits for ci
#24229 opened Jan 30, 2024 by RocMarshal • Draft updated Jun 14, 2024
1
[FLINK-34487][ci] Adds Python Wheels nightly GHA workflow component=BuildSystem/CI
#24426 opened Mar 1, 2024 by morazow Loading… updated Jun 14, 2024
74
[FLINK-35512][flink-clients] Don't depend on the flink-clients jar actually existing. component=<none>
#24931 opened Jun 13, 2024 by SamBarker Loading… updated Jun 14, 2024
2
FLINK-35596: Make DescriptionElement serializable component=<none>
#24935 opened Jun 14, 2024 by venkata91 Loading… updated Jun 14, 2024
2
[FLINK-33192] Fix Memory Leak in WindowOperator due to Improper Timer Cleanup component=Runtime/StateBackends
#24917 opened Jun 8, 2024 by kartikeypant Loading… updated Jun 14, 2024
2
[FLINK-35595][core] MailboxProcessor#processMailsWhenDefaultActionUnavailable avoids allocating Optional component=API/Core
#24923 opened Jun 12, 2024 by schlosna Loading… updated Jun 14, 2024
1
[FLINK-35165][runtime/coordination] AdaptiveBatch Scheduler should not restrict the default source parall… component=Runtime/Coordination
#24736 opened Apr 28, 2024 by venkata91 Loading… updated Jun 13, 2024
10
[FLINK-33130]reuse source and sink operator io metrics for task component=<none>
#23454 opened Sep 23, 2023 by xbthink Loading… updated Jun 13, 2024
4
[FLINK-34896][table] Migrate CorrelateSortToRankRule to java component=TableSQL/Planner
#24545 opened Mar 20, 2024 by snuyanzin Loading… updated Jun 13, 2024
5
[FLINK-30400][docs] Add some notes about changes for flink-connector-base dependency in externalized connectors component=Connectors/Common
#24930 opened Jun 13, 2024 by ruanhang1993 Loading… updated Jun 13, 2024
2
[DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent component=Formats
#24482 opened Mar 11, 2024 by anupamaggarwal • Draft updated Jun 13, 2024
19
[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 13, 2024
4
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-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
[FLINK-XXX][planner] Support custom shuffle for lookup join
#24920 opened Jun 10, 2024 by WencongLiu Loading… updated Jun 12, 2024
1
[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
ProTip! Type g i on any issue or pull request to go back to the issue listing page.