Skip to content

Issues: apache/beam

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Clear current search query, filters, and sorts
129 Open 304 Closed
129 Open 304 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
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Issues list

[Bug]: withOutputTags (aka side output) requires ParDo to run on each output separately bug java P2 spark
#34333 opened Mar 18, 2025 by shai-rubin
2 of 17 tasks
[Bug]: SparkRunner reads input data twice when using FileIO bug P2 spark
#33771 opened Jan 27, 2025 by JozoVilcek
1 of 17 tasks
@JozoVilcek
1
[Feature Request]: Support ProcessingTime Timer in Spark Runner java new feature P2 spark
#33633 opened Jan 17, 2025 by twosom
2 of 17 tasks
@twosom
1
[Feature Request]: Support OrderedListState in SparkRunner java new feature P2 spark
#33211 opened Nov 25, 2024 by twosom
2 of 17 tasks
1
@twosom
2
[Bug]: TextIO.read() runs in only one executor when using SparkStructuredStreamingRunner but runs in distributed manner with SparkRunner awaiting triage bug java P2 spark
#32231 opened Aug 18, 2024 by DebajitKumarPhukan
2 of 17 tasks
[Task]: Fill Runner Metrics support gap in Sources awaiting triage direct flink java P2 spark task
#32021 opened Jul 30, 2024 by Abacn
3 of 17 tasks
1
[Bug]: MetricUpdates.isEmpty check does not check for gaugeUpdates bug dataflow flink go java jet P2 python samza spark twister2 typescript
#31630 opened Jun 18, 2024 by rohitsinha54
10 of 16 tasks
@rohitsinha54
1
[Bug]: Portable Spark 3 Streaming runner appears to have GBK bugs, cannot execute Redistribute composite correctly bug P2 spark
#31234 opened May 9, 2024 by kennknowles
1 of 16 tasks
@Zawa-ll
3
[Bug]: Portable translation or SDK harness appears to have a bug in GBK coders awaiting triage bug flink P2 python samza spark
#31231 opened May 9, 2024 by kennknowles
4 of 16 tasks
[Bug]: GBK with global window must fit all values for a key into a memory awaiting triage bug P3 spark
#30184 opened Feb 1, 2024 by mareksimunek
1 of 16 tasks
1
[Bug]: SparkRunner log plumbing for Python SDK not working properly bug P3 python spark
#29683 opened Dec 8, 2023 by phoerious
2 of 16 tasks
7
[Task]: Align Spark/Hadoop versions in Spark multiple-versions unit/VR tests awaiting triage java P3 spark task
#27562 opened Jul 19, 2023 by aromanenko-dev
2 of 15 tasks
2
[Task]: FilesToStage breaks Spark on YARN java P2 spark task
#26692 opened May 15, 2023 by JozoVilcek
2 of 15 tasks
@Zawa-ll
1
[Bug]: Nexmark Python fails to fetch metrics on Flink and Spark runners bug flink P3 python spark
#24737 opened Dec 20, 2022 by apilloud
3 of 15 tasks
1
[Bug]: No parallelization for ReadFromParquet (or any Python Read transforms) in Spark RDD Runner bug P2 portability python runners spark
#24422 opened Nov 29, 2022 by cozos
[Bug]: No parallelism using WriteToParquet in Apache Spark bug io P2 parquet python spark
#24365 opened Nov 27, 2022 by cozos
9
[Bug]: Beam Pipeline does not halt execution while running on non local Spark Cluster bug harness P3 portability python spark
#23932 opened Nov 1, 2022 by nitinlkoin1984
10
(Spark dataset runner) Investigate performance issue in TPC-DS Query 83 runners spark tpcds For TPC-DS benchmark related tasks
#23845 opened Oct 26, 2022 by mosche
@mosche
1
[Task]: Update roadmap for Spark runner P2 runners spark task website
#23801 opened Oct 24, 2022 by mosche
1
[Bug]: Spark "uber jar" job server fails on cluster with NoSuchFileException bug portability spark
#23439 opened Sep 30, 2022 by mosche
2
[Task]: Improve documentation of PortableRunner for usage with Spark cross-language documentation portability runners spark task website
#23438 opened Sep 30, 2022 by mosche
[Bug]: Issues with Watermark propagation in Spark runner (streaming) bug P2 runners spark tests
#23129 opened Sep 9, 2022 by mosche
5
[Feature Request]: Support onWindowExpiration in Spark runner so that GroupIntoBatches can be used new feature P2 runners spark
#22524 opened Jul 29, 2022 by mosche
2
[Feature Request]: Use Spark 3 plugin framework to support metrics for Spark runner new feature P2 runners spark
#22384 opened Jul 21, 2022 by mosche
@mosche
1
Running Apache Beam pipeline on Azure Databricks bug io java kafka P2 runners spark
#21572 opened Jun 5, 2022 by damccorm
ProTip! Find all open issues with in progress development work with linked:pr.