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
26 Open 554 Closed
26 Open 554 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]: beam.Map function outputs no data after beam.GroupByKey using DataflowRunner bug dataflow P1 python
#34360 opened Mar 20, 2025 by bgalvao
2 of 17 tasks
3
[Failing Test]: org.apache.beam.runners.dataflow.worker.streaming.harness.FanOutStreamingEngineWorkerHarnessTest.testOnNewWorkerMetadata_redistributesBudget bug failing test flake P1 tests
#34171 opened Mar 4, 2025 by Naireen
1 of 17 tasks
@Amar3tto @akashorabek
[Flaky Py SDK Snapshots]: Publish Beam SDK Snapshots is failing for Python distroless container bug failing test P1 permared python tests
#33744 opened Jan 23, 2025 by ahmedabu98
1 of 17 tasks
@Amar3tto
3
[Bug]: Non Retained Messages missing after MqttIO.Read checkpoint restore awaiting triage bug flink io java P1
#32997 opened Nov 1, 2024 by SamLeurink
3 of 17 tasks
[Bug]: Unable to Restart Google Spanner Change Streams Consumer due to tableExists(table_name) bug awaiting triage bug io java P1
#32509 opened Sep 19, 2024 by NimzyMaina
2 of 17 tasks
2
14
The IcebergIO Integration Tests job is flaky bug flaky_test P1 workflow_id: 100080955
#31931 opened Jul 18, 2024 by github-actions bot
1
@Amar3tto
7
[Failing Test]: Onnx inference unit tests are failing. awaiting triage bug failing test P1 permared python tests
#31254 opened May 10, 2024 by tvalentyn
1 of 16 tasks
1
The PreCommit Java job is flaky bug flaky_test P1 workflow_id: 67750765
#30683 opened Mar 20, 2024 by github-actions bot 2.65.0 Release
6
The PostCommit XVR GoUsingJava Dataflow job is flaky bug flaky_test P1 workflow_id: 69016554
#30519 opened Mar 5, 2024 by github-actions bot
@Amar3tto
5
The PostCommit Python job is flaky bug flaky_test P1 workflow_id: 69778299
#30513 opened Mar 5, 2024 by github-actions bot
4
@Amar3tto @akashorabek
52
The PostCommit Java InfluxDbIO Integration Test job is flaky bug flaky_test P1 workflow_id: 71050474
#30510 opened Mar 5, 2024 by github-actions bot 2.59.0 Release
@Amar3tto
3
[Bug]: FixedWindows not working for large Kafka topic awaiting triage bug dataflow java P1
#29971 opened Jan 10, 2024 by oemergenc
2 of 16 tasks
[Bug]: WriteToFiles in python leave few records in temp directory when writing to large number (100+) of files bug dataflow P1 python
#29515 opened Nov 22, 2023 by awadhoot-sq
2 of 16 tasks
1
16
[Bug]: FnAPI Java SDK Harness doesn't update user counters in OnTimer callback functions bug dataflow java P1
#29099 opened Oct 20, 2023 by y1chi
2 of 16 tasks
5
[Bug]: EFO Kinesis IO reader provided by apache beam does not pick the event time for watermarking awaiting triage bug java P1
#28760 opened Oct 2, 2023 by sjmittal
1 of 16 tasks
2
[Bug]: BigQuerySourceBase does not propagate a Coder to AvroSource awaiting triage bug io P1
#26329 opened Apr 18, 2023 by piter75
1 of 15 tasks
1
10
[Bug]: Unable to create exactly-once Flink pipeline with stream source and file sink bug flink java P1
#26041 opened Mar 30, 2023 by psolomin
2 of 15 tasks
4
[Bug]: KinesisIO processing-time watermarking can cause data loss bug flink java P1
#25975 opened Mar 25, 2023 by psolomin
2 of 15 tasks
@psolomin
20
[Task]: Support more Beam portable schema types as Python types P1 python schemas Issues related to Beam Schemas task types
#25946 opened Mar 23, 2023 by ahmedabu98
1 of 15 tasks
3
[Bug]: Race condition in Python SDK Harness ProcessBundleProgress bug P1 python
#24776 opened Dec 24, 2022 by cozos
1 of 15 tasks
8
[Bug]: Default PubsubMessage coder will drop message id and orderingKey bug gcp io java P1
#23525 opened Oct 6, 2022 by TheNeuralBit
1
12
[Bug]: Beam Python failure for dataflow_exercise_metrics_pipeline_test.ExerciseMetricsPipelineTest.test_metrics_it bug core P1 python
#22605 opened Aug 5, 2022 by yeandy
12
FnRunnerTest with non-trivial (order 1000 elements) numpy input flakes in non-cython environment bug core flake P1 python
#21643 opened Jun 5, 2022 by damccorm
9
Make cloudpickle the default pickle library core improvement P1 python
#21298 opened Jun 4, 2022 by damccorm
@claudevdm
3
Python DirectRunner does not emit data at GC time bug core direct P1 python runners
#21260 opened Jun 4, 2022 by damccorm
1
ProTip! Type g i on any issue or pull request to go back to the issue listing page.