-
Notifications
You must be signed in to change notification settings - Fork 13.5k
Pull requests: apache/flink
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-37728][python] fix incorrect import org.apache.flink.table.runtime.operators.window.Window
component=API/Python
#26506
opened Apr 25, 2025 by
suez1224
Loading…
Makes Async calcs share correlate split rule with Python
#26505
opened Apr 24, 2025 by
AlanConfluent
Loading…
[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
Loading…
[FLINK-37718] Refactor ApplicationSubmissionContextReflector to centralize method retrieval and invocation.
component=<none>
#26502
opened Apr 24, 2025 by
joyCurry30
Loading…
[FLINK-36659][docs] Update Kafka connector docs for 4.0.0
component=Connectors/JDBC
#26501
opened Apr 24, 2025 by
AHeise
Loading…
[FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph
component=Deployment/YARN
#26500
opened Apr 24, 2025 by
beliefer
Loading…
[FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot
component=Connectors/FileSystem
#26498
opened Apr 22, 2025 by
lianghongjia6
Loading…
[FLINK-37693][state] Avoid reading NOT_OWNED file by local file system when restoring
component=Runtime/StateBackends
#26497
opened Apr 22, 2025 by
masteryhx
Loading…
[FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils
component=Client/JobSubmission
#26493
opened Apr 22, 2025 by
beliefer
Loading…
[FLINK-37709][metrics] add file descriptor jvm metrics
component=Runtime/Metrics
#26492
opened Apr 21, 2025 by
HuangZhenQiu
Loading…
[hotfix] Rename SessionDispatcherFactory to DefaultDispatcherFactory
#26490
opened Apr 21, 2025 by
beliefer
Loading…
[FLINK-37700][table-planner] Fix SQL parse exception when creating a view with PTF
component=TableSQL/Planner
#26487
opened Apr 20, 2025 by
juntaozhang
Loading…
[hotfix][core] Optimize the merge logic lines calling in Histogram.java.
#26486
opened Apr 19, 2025 by
RocMarshal
Loading…
[hotfix][core] Replace the concating on strings with the placeholder in log lines
#26485
opened Apr 19, 2025 by
RocMarshal
Loading…
[FLINK-37308] Support pauseOrResumeSplits in HybridSource
component=Connectors/Common
#26483
opened Apr 19, 2025 by
xccui
Loading…
[FLINK-37698] Rename fromSchedulerNg to fromWithinExecutionGraph
component=Runtime/Task
#26482
opened Apr 18, 2025 by
beliefer
Loading…
[hotfix][test] Remove redundant keywords and lines for ForStGeneralMultiGetOperationTest.java
#26481
opened Apr 18, 2025 by
RocMarshal
Loading…
[FLINK-36767] Bumped
cyclonedx-maven-plugin to 2.9.1 to resolve CVE-2024-38374
#26476
opened Apr 17, 2025 by
vivek807
Loading…
[hotfix] Pin version of build-helper-maven-plugin across profiles and…
#26475
opened Apr 17, 2025 by
dmvk
Loading…
[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
Loading…
[FLINK-18590][json] Support json array explode to multi messages
component=Formats
#26473
opened Apr 17, 2025 by
lianghongjia6
Loading…
[FLINK-37689] Improve the comments and variable names for TaskMailbox
component=Runtime/Task
#26469
opened Apr 16, 2025 by
beliefer
Loading…
Previous Next
ProTip!
Adding no:label will show everything without a label.