Skip to content

Pull requests: apache/flink

New pull request New
1,243 Open 24,424 Closed
1,243 Open 24,424 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-36688][table-planner] Sort metadata keys when reusing source component=TableSQL/Planner
#25681 opened Nov 25, 2024 by xuyangzhong Loading…
1
[FLINK-36773][table] Introduce new Group Agg Operator with Async State API component=TableSQL/Runtime
#25680 opened Nov 25, 2024 by xuyangzhong Loading…
1
[FLINK-36451][runtime] Replaces LeaderElection#hasLeadership with LeaderElection#runAsLeader component=Runtime/Coordination
#25679 opened Nov 22, 2024 by XComp Loading…
1
[FLINK-36751] Fix PausableRelativeClock does not pause when the source only has one split component=API/DataStream
#25678 opened Nov 22, 2024 by haishui126 Loading…
2
(1.20 backport)[FLINK-36751] Fix PausableRelativeClock does not pause when the source only has one split component=API/DataStream
#25677 opened Nov 22, 2024 by haishui126 Loading…
1
[FLINK-36749][state/forst] Implement rescaling for ForStStateBackend component=<none>
#25676 opened Nov 22, 2024 by fredia Loading…
1
[FLINK-36755][yarn][k8s] Relax the limit about the pipeline.jar must have one in application mode component=Deployment/Kubernetes component=Deployment/YARN
#25674 opened Nov 22, 2024 by fsk119 Loading…
8
[hotfix] [docs]Fix miss semicolon on SELECT & WHERE clause example sql
#25673 opened Nov 22, 2024 by camilesing Loading…
3
[FLINK-36769] support fury serializer for pyflink component=API/Python
#25672 opened Nov 21, 2024 by kaori-seasons • Draft
2
[FLINK-36764] Add checkpoint type and unaligned flag to the checkpoint trace component=Runtime/Checkpointing component=Runtime/Metrics
#25671 opened Nov 21, 2024 by pnowojski Loading…
5
[FLINK-36739] [WebFrontend] Update the NodeJS to v22.11.0 (LTS) component=Runtime/WebFrontend
#25670 opened Nov 20, 2024 by mehdid93 Loading…
3
[hotfix] [docs] Update table environment variable name in common.md
#25669 opened Nov 20, 2024 by Huachao Loading…
3
[FLINK-36745][docs] Make FixedSizeSplitFetcherManager and FixedFetcherSizeSourceReader examples match Flink 2.0-preview API component=Connectors/Common component=Documentation
#25667 opened Nov 18, 2024 by kaygorodov Loading…
8
fix: class-loading-issue
#25666 opened Nov 18, 2024 by ammu20-dev • Draft
1
[FLINK-36704] Update TypeInference with StaticArgument and StateTypeStrategy component=TableSQL/API
#25665 opened Nov 18, 2024 by twalthr Loading…
9
Event latency does not equal window triggering
#25664 opened Nov 18, 2024 by a4566 Loading…
4
[FLINK-36455] Sinks retry synchronously [1.20] component=API/Core
#25661 opened Nov 15, 2024 by AHeise Loading…
2
[FLINK-36379] Improve (Global)Committer with UC disabled [1.20] component=<none>
#25660 opened Nov 15, 2024 by AHeise Loading…
9
[FLINK-36068][runtime] Support scheduling based on adaptive job graph. component=Runtime/Coordination
#25658 opened Nov 15, 2024 by JunRuiLee • Draft
1
[FLINK-28897] [TABLE-SQL] Fail to use udf in added jar when enabling checkpoint component=TableSQL/Runtime
#25656 opened Nov 14, 2024 by ammu20-dev Loading…
8
Upgrade com.squareup.okio:okio
#25649 opened Nov 12, 2024 by g-s-eire Loading…
2
[FLINK-16077][docs] Translate "Custom State Serialization" page into Chinese component=chinese-translation component=Documentation
#25648 opened Nov 12, 2024 by liboshuai01 Loading…
3
[FLINK-35966][runtime] Introduce the TASKS for TaskManagerLoadBalanceMode enum component=Runtime/Coordination
#25647 opened Nov 12, 2024 by RocMarshal Loading…
16
[FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 component=Formats
#25646 opened Nov 12, 2024 by MartijnVisser Loading…
3
[FLINK-35334][flink-table] Split constructor of generated code if it is too large. component=TableSQL/API component=TableSQL/Runtime
#25644 opened Nov 12, 2024 by littleeleventhwolf Loading…
6
ProTip! Exclude everything labeled bug with -label:bug.