Skip to content

Pull requests: apache/flink

New pull request New
1,261 Open 24,565 Closed
1,261 Open 24,565 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-36880][network] Hybrid shuffle supports job master failover if only external tier used
#25842 opened Dec 23, 2024 by reswqa • Draft
[FLINK-36949] Make getCurrentKey of async state operators return the ground truth
#25841 opened Dec 23, 2024 by Zakelly Loading…
3
[FLINK-33117][docs] Fix scala example for NamedParameterClass component=Documentation
#25840 opened Dec 22, 2024 by snuyanzin Loading…
1
[FLINK-36948][tests] Remove deprecated FlinkMatchers component=Tests
#25839 opened Dec 22, 2024 by snuyanzin Loading…
1
[FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB component=Runtime/StateBackends
#25838 opened Dec 22, 2024 by Shawnsuun Loading…
2
[FLINK-34558][state] Support tracking state size component=Runtime/StateBackends
#25837 opened Dec 22, 2024 by hejufang Loading…
1
[MINOR] Rename PunctuatedWatermarkStrategyWrapper with PunctuatedWatermarkAssignerWrapper
#25836 opened Dec 21, 2024 by beliefer Loading…
1
[MINOR] Deprecated StreamSink and SinkOperator
#25835 opened Dec 21, 2024 by beliefer Loading…
1
[FLINK-35014] SqlNode to operation conversion for models component=<none>
#25834 opened Dec 20, 2024 by lihaosky Loading…
3
[FLINK-33117][table][docs] Fix scala example in udfs page component=Documentation
#25833 opened Dec 20, 2024 by afedulov Loading…
5
[FLINK-36946][Metrics] Optimize sink operator name truncate component=Runtime/Metrics
#25832 opened Dec 20, 2024 by Tartarus0zm Loading…
@1996fanrui
8
[FLINK-36944][DataStream/API] Introduce 'enableAsycState' in KeyedStream interfaces and implement reduce operator component=API/DataStream
#25831 opened Dec 20, 2024 by Zakelly Loading…
3
[BP-1.20][FLINK-36740] [WebFrontend] Update frontend dependencies to address vulnerabilities component=Runtime/WebFrontend
#25830 opened Dec 20, 2024 by mehdid93 Loading…
3
[BP-1.20][FLINK-36689][Runtime/Web Frontend] Update ng-zorro-antd to v18 component=Runtime/WebFrontend
#25829 opened Dec 20, 2024 by mehdid93 Loading…
1
[FLINK-36941][docs] Update DATE_FORMAT Doc and Python Tests component=Documentation
#25828 opened Dec 20, 2024 by yiyutian1 Loading…
16
[BP-1.20][FLINK-34194] Update CI to Ubuntu 22.04 (Jammy) component=BuildSystem/CI
#25827 opened Dec 20, 2024 by mehdid93 Loading…
1
[FLINK-xx][table] Add more Calcite PruneEmptyRules
#25826 opened Dec 20, 2024 by liuyongvs Loading…
1
[FLINK-36911][table] Add more Calcite Reduce Expression Rules component=TableSQL/Planner
#25825 opened Dec 20, 2024 by liuyongvs Loading…
1
[FLINK-xx][table] Remove RelBuilder
#25823 opened Dec 20, 2024 by liuyongvs Loading…
1
[FLINK-36608][table-runtime] Support dynamic StreamGraph optimization for AdaptiveBroadcastJoinOperator component=TableSQL/Planner
#25822 opened Dec 19, 2024 by SinBex Loading…
2
[hotfix] [docs] Fix typo in Flink Overview
#25820 opened Dec 19, 2024 by philhofftw Loading…
2
[FLINK-36936][table] Introduce UpdatableTopNFunction in Rank with Async State API component=TableSQL/Runtime
#25819 opened Dec 19, 2024 by Au-Miner • Draft
1
[FLINK-36935][state/forst] Implement fast link for ForStFileSystem component=<none>
#25818 opened Dec 19, 2024 by fredia Loading…
4
[FLINK-36926][table] Introduce window join operator with async state api component=TableSQL/Runtime
#25815 opened Dec 18, 2024 by xuyangzhong Loading…
4
[FLINK-36925][table] Introduce SemiAntiJoinOperator in Join with Async State API component=TableSQL/Runtime
#25814 opened Dec 18, 2024 by Au-Miner Loading…
5
ProTip! Follow long discussions with comments:>50.