-
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-37745] Serialize partial deletes in ChangelogMode to JSON
component=TableSQL/Planner
#26516
opened Apr 28, 2025 by
dawidwys
Loading…
[FLINK-37746] Added serialVersionUID in MapTypeInfo class
component=<none>
#26515
opened Apr 28, 2025 by
pranav234
Loading…
[FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source
component=TableSQL/Planner
#26514
opened Apr 28, 2025 by
morazow
Loading…
[FLINK-37722] Eliminate redundant field initialization of PojoSerializer
component=API/TypeSerializationSystem
#26513
opened Apr 27, 2025 by
X-czh
Loading…
Verify Flaky Behavior in Apache Flink CEP Operator Test Using GitHub ActionsVerify cep flaky test
#26511
opened Apr 26, 2025 by
Md-Arif-Hasan
Loading…
[hotfix][python] Add pandas type annotations for TableEnvironment.from_pandas and Table.to_pandas
#26510
opened Apr 26, 2025 by
autophagy
Loading…
[FLINK-37523][CI] Fix Python test/e2e tests missing libpython/python headers
component=API/Python
#26509
opened Apr 26, 2025 by
autophagy
Loading…
[FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema
component=<none>
#26507
opened Apr 25, 2025 by
pawel-big-lebowski
Loading…
[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-37711] Remove unused getJobGraph from PipelineExecutorUtils
component=Client/JobSubmission
#26493
opened Apr 22, 2025 by
beliefer
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…
Previous Next
ProTip!
no:milestone will show everything without a milestone.