Skip to content

Pull requests: apache/streampark

New pull request New
41 Open 2,641 Closed
41 Open 2,641 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
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[Flink] Fix Flink 2.x Flink SQL on Yarn/K8s Application mode BACKEND FLINK
#4509 opened Sep 2, 2026 by shangeyao Contributor Loading…
1 of 4 tasks
1
1
[Fix] Handle NPE when HADOOP_HOME is not set in K8s application mode (#4304) BACKEND
#4505 opened Aug 20, 2026 by zhang-arvin Loading…
1
1
[Fix] Fix savepoint state stuck in SAVEPOINTING after savepoint completion (#4338) BACKEND
#4504 opened Aug 20, 2026 by zhang-arvin Loading…
2 tasks done
1
1
[BugFix] Add spring.sql.init auto-initialization for MySQL and PostgreSQL (#4340) BACKEND
#4503 opened Aug 20, 2026 by zhang-arvin Loading…
1
[Fix] Fix memory sizes config not taking effect in Yarn mode FLINK
#4502 opened Aug 18, 2026 by zhang-arvin Loading…
1
1
[Fix] Make WebSocket ServerEndpointExporter conditional to avoid ServerContainer not available BACKEND
#4501 opened Aug 18, 2026 by zhang-arvin Loading…
1
1
[Console] Report Flink and Spark job lineage to Gravitino via OpenLineage BACKEND BUILD FLINK WEB UI
#4498 opened Aug 14, 2026 by 88fantasy Contributor Loading…
1
1
[Flink] Fix Flink SQL job submission failures on the client path BACKEND BUILD FLINK
#4496 opened Aug 14, 2026 by 88fantasy Contributor Loading…
4
1
[Build] Allow the legacy SecurityManager for FlinkClient#submit on JDK 18+ BACKEND BUILD
#4487 opened Aug 12, 2026 by 88fantasy Contributor Loading…
1
2
[E2E] Migrate Flink deploy tests to REST API and expand version matrix BUILD INFRA
#4478 opened Aug 7, 2026 by shangeyao Contributor • Draft
5 tasks
1
[K8s] Fix failed application cancellation state race BACKEND FLINK KUBERNETES WEB UI
#4459 opened Jul 25, 2026 by johntomcat7408-cmyk Loading…
1
1
[Feature][Flink] Define FlinkTableJob and FlinkStreamTableJob Java base classes FLINK
#4441 opened Jul 21, 2026 by ocb3916 Loading…
1 of 3 tasks
2
[Feature][Common] Migrate conf package from Scala to Java BACKEND INFRA
#4440 opened Jul 19, 2026 by och5351 • Draft
1
1
[Feature][Flink] Define FlinkStreamingJob Java lifecycle base class BUILD FLINK
#4436 opened Jul 19, 2026 by och5351 • Draft
1 of 3 tasks
8
[Spark] Baseline Spark 3.5+ and add Spark 4.x support BACKEND BUILD FLINK INFRA KUBERNETES SPARK WEB UI YARN
#4420 opened Jul 6, 2026 by shangeyao Contributor • Draft
2 of 4 tasks
1
58
[Bug] Revert FlinkEnv config path persistence regression BACKEND
#4375 opened Jun 25, 2026 by michael1991 Loading…
2
[ISSUE-4203][Bug] Preserve quoted program args BACKEND
#4365 opened Jun 22, 2026 by hutiefang76 Loading…
1
1
[ISSUE-4157][Bug] Parse vendor suffixed Flink versions BACKEND
#4364 opened Jun 22, 2026 by hutiefang76 Loading…
1
1
[ISSUE-4072][Bug] Use SSL when checking alert email BACKEND
#4363 opened Jun 22, 2026 by hutiefang76 Loading…
1
[ISSUE-4339][Bug] Fix latest savepoint lookup BACKEND
#4362 opened Jun 21, 2026 by hutiefang76 Loading…
1
2
[ISSUE-4322][Bug] Fix OpenAPI token authentication BACKEND
#4361 opened Jun 21, 2026 by hutiefang76 Loading…
1
1
[Bug] Fix Yarn running state fallback BACKEND
#4360 opened Jun 21, 2026 by hutiefang76 Loading…
1
1
[ISSUE-4315][Bug] Fix multiline dynamic properties parsing BACKEND
#4359 opened Jun 21, 2026 by hutiefang76 Loading…
1
1
[ISSUE-4323][Bug] Fix flink conf path recovery BACKEND
#4358 opened Jun 20, 2026 by hutiefang76 Loading…
1
1
[bug-4356] After obtaining an exception in task status from Flink, th… BACKEND
#4357 opened Jun 4, 2026 by niumy0701 Contributor Loading…
1
1
ProTip! no:milestone will show everything without a milestone.