Skip to content

Pull requests: apache/flink

New pull request New
456 Open 26,036 Closed
456 Open 26,036 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-26425][yarn] Support rolling log aggregation component=Deployment/YARN
#26508 opened Apr 25, 2025 by ferenc-csaky • Approved
6
[FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema component=<none>
#26507 opened Apr 25, 2025 by pawel-big-lebowski
6
[FLINK-37728][python] fix incorrect import org.apache.flink.table.runtime.operators.window.Window component=API/Python
#26506 opened Apr 25, 2025 by suez1224
1
Makes Async calcs share correlate split rule with Python
#26505 opened Apr 24, 2025 by AlanConfluent
1
Fixes janino bug returning incorrect results
#26504 opened Apr 24, 2025 by AlanConfluent
1
[FLINK-37720][table-planner] Enable sink reuse table optimizer by default and apply plan changes to existing test cases component=<none>
#26503 opened Apr 24, 2025 by xiangyuf
5
[FLINK-37718] Refactor ApplicationSubmissionContextReflector to centralize method retrieval and invocation. component=<none>
#26502 opened Apr 24, 2025 by joyCurry30
1
[FLINK-36659][docs] Update Kafka connector docs for 4.0.0 component=Connectors/JDBC
#26501 opened Apr 24, 2025 by AHeise
2
[FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph component=Deployment/YARN
#26500 opened Apr 24, 2025 by beliefer
2
[FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot component=Connectors/FileSystem
#26498 opened Apr 22, 2025 by lianghongjia6
8
[FLINK-37693][state] Avoid reading NOT_OWNED file by local file system when restoring component=Runtime/StateBackends
#26497 opened Apr 22, 2025 by masteryhx
5
[FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils component=Client/JobSubmission
#26493 opened Apr 22, 2025 by beliefer
5
[FLINK-37709][metrics] add file descriptor jvm metrics component=Runtime/Metrics
#26492 opened Apr 21, 2025 by HuangZhenQiu • Approved
6
[hotfix] Rename SessionDispatcherFactory to DefaultDispatcherFactory
#26490 opened Apr 21, 2025 by beliefer
2
[FLINK-37700][table-planner] Fix SQL parse exception when creating a view with PTF component=TableSQL/Planner
#26487 opened Apr 20, 2025 by juntaozhang
1
[hotfix][core] Optimize the merge logic lines calling in Histogram.java.
#26486 opened Apr 19, 2025 by RocMarshal
5
[hotfix][core] Replace the concating on strings with the placeholder in log lines
#26485 opened Apr 19, 2025 by RocMarshal
1
[hotfix][core] Minor polish for CliFrontend.java
#26484 opened Apr 19, 2025 by RocMarshal
2
[FLINK-37308] Support pauseOrResumeSplits in HybridSource component=Connectors/Common
#26483 opened Apr 19, 2025 by xccui
2
[FLINK-37698] Rename fromSchedulerNg to fromWithinExecutionGraph component=Runtime/Task
#26482 opened Apr 18, 2025 by beliefer
5
[hotfix][test] Remove redundant keywords and lines for ForStGeneralMultiGetOperationTest.java
#26481 opened Apr 18, 2025 by RocMarshal
4
[FLINK-36767] Bumped cyclonedx-maven-plugin to 2.9.1 to resolve CVE-2024-38374
#26476 opened Apr 17, 2025 by vivek807
1
[hotfix] Pin version of build-helper-maven-plugin across profiles and…
#26475 opened Apr 17, 2025 by dmvk • Approved
1
[FLINK-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions component=TableSQL/API
#26474 opened Apr 17, 2025 by gustavodemorais
10
[FLINK-18590][json] Support json array explode to multi messages component=Formats
#26473 opened Apr 17, 2025 by lianghongjia6 • Approved
25
ProTip! Follow long discussions with comments:>50.