Skip to content

Pull requests: apache/flink

New pull request New
1,214 Open 24,981 Closed
1,214 Open 24,981 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-37382][runtime] Early optimization for adaptive join when either input is below broadcast threshold. component=Runtime/Coordination
#26211 opened Feb 25, 2025 by SinBex Loading…
1
[FLINK-37384][runtime] Optimize the parallelism decide logic for pointwise component=Runtime/Coordination
#26210 opened Feb 25, 2025 by noorall Loading…
1
[FLINK-37381] [doc] Fix typo in Join document component=Documentation
#26209 opened Feb 25, 2025 by cnsky1103 Loading…
2
[BP-2.0][FLINK-37162][docs] Add sinks.md to describe Flink's Data Sink API component=Documentation
#26208 opened Feb 25, 2025 by lvyanquan Loading…
1
[FLINK-36585][connector/common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop component=Connectors/Common
#26205 opened Feb 24, 2025 by becketqin Loading…
2
[FLINK-36172][metrics][rest] Optimize transient metric cleanup component=Runtime/Metrics component=Runtime/REST
#26204 opened Feb 24, 2025 by fdc91 Loading…
1
[FLINK-37383][flink-examples]Correct throttling logic on ThrottledIterator component=Examples
#26203 opened Feb 24, 2025 by rafaelzimmermann Loading…
1
[FLINK-37367][state/forst] Make ForSt inherit unloaded SST files after restorations. component=<none>
#26202 opened Feb 24, 2025 by AlexYinHan Loading…
1
[FLINK-37357][table-planner]Migrating SqlNode conversion logic from SqlNodeToOperationConversion to SqlNodeConverters component=TableSQL/Planner
#26201 opened Feb 24, 2025 by Milesian111 Loading…
3
[FLINK-37374][table] Add the built-in function JSON for JSON_ARRAY component=TableSQL/API
#26199 opened Feb 24, 2025 by gustavodemorais Loading…
6
[FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese component=chinese-translation component=Documentation
#26196 opened Feb 23, 2025 by JinkunLiu Loading…
1
[FLINK-36652] Upgrade Apache ORC Version to 1.9.4 component=Formats
#26195 opened Feb 23, 2025 by dyccode Loading…
1
[hotfix][tests] Use Junit5 import.
#26193 opened Feb 22, 2025 by slfan1989 Loading…
1
[FLINK-36324] Harden runtime error cases for table builtin functions component=TableSQL/Planner
#26190 opened Feb 21, 2025 by dawidwys Loading…
3
[BP-2.0][FLINK-37274] Add examples for DataStream V2 component=API/DataStream
#26179 opened Feb 20, 2025 by codenohup Loading…
1
[FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API component=API/Python
#26167 opened Feb 17, 2025 by autophagy Loading…
28
[FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False component=TableSQL/Planner
#26162 opened Feb 15, 2025 by shameersss1 Loading…
10
[FLINK-37328][FileSystems] Upgrade GCS connector to 2.2.26. component=FileSystems
#26160 opened Feb 15, 2025 by cnauroth Loading…
2
[FLINK-37327] [Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows component=Formats
#26159 opened Feb 14, 2025 by klam-shop Loading…
4
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 Loading…
5
[FLINK-37315][table-planner] Improve SelectivityEstimator#estimateEquals for columns in VARCHAR type component=TableSQL/Planner
#26155 opened Feb 13, 2025 by bgeng777 Loading…
5
[FLINK-37269][table] Add new DESCRIPTOR type component=TableSQL/API component=TableSQL/Planner
#26144 opened Feb 11, 2025 by twalthr Loading…
4
[hotfix] Integrate hive connector docs
#26135 opened Feb 10, 2025 by snuyanzin Loading…
3
[FLINK-37289][table] Resolve JVM bytecode size limit exceeded in <init> method due to excessive field initializations in SQL job component=<none>
#26128 opened Feb 9, 2025 by littleeleventhwolf Loading…
4
[hotfix][state/rocksdb] Use try-with-resources to close RocksStateKeysIterator and fix some typos.
#26126 opened Feb 8, 2025 by littleeleventhwolf Loading…
7
ProTip! Type g i on any issue or pull request to go back to the issue listing page.