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

4,444 Open 3,025 Closed
4,444 Open 3,025 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.io.WriteToCsv ignores num_shards argument. awaiting triage bug P2 python
#34188 opened Mar 6, 2025 by ganesh4991
1 of 17 tasks
2
[Bug]: FlinkRunner never calls finish_bundle and OOM eventually awaiting triage bug flink P2 python
#34178 opened Mar 5, 2025 by muyangyuapple
2 of 17 tasks
[Bug]: Provisioning runners fails awaiting triage bug infra P2
#34176 opened Mar 4, 2025 by damccorm
1 of 17 tasks
2
[Failing Test]: org.apache.beam.sdk.io.mqtt.MqttIOTest.testReadWithMetadata awaiting triage bug failing test flake P1 tests
#34175 opened Mar 4, 2025 by Naireen
17 tasks
1
[Failing Test]: org.apache.beam.runners.flink.translation.wrappers.streaming.io.source.unbounded.FlinkUnboundedSourceReaderTest.testIsAvailableAlwaysWakenUp bug failing test flake flink P1 tests
#34174 opened Mar 4, 2025 by Naireen
1 of 17 tasks
@Amar3tto
[Failing Test]: org.apache.beam.sdk.transforms.RedistributeTest.testRedistributeAfterFixedWindows bug failing test flake java P1 tests
#34172 opened Mar 4, 2025 by Naireen
1 of 17 tasks
@Amar3tto
[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
[Task]: Close feature gaps between regular and CDC Iceberg sources IcebergIO IcebergIO: can only be used through ManagedIO io java P2 task
#34168 opened Mar 4, 2025 by ahmedabu98
2 of 17 tasks
@ahmedabu98
[Bug]: cassandraIO ReadAll does not let a pipeline handle or retry exceptions awaiting triage bug java P2
#34160 opened Mar 4, 2025 by VardhanThigle
1 of 17 tasks
2
[Feature Request]: Add ClickHouse Resource Manager for Integration Tests clickhouse io new feature P2 tests
#34159 opened Mar 4, 2025 by BentsiLeviav
1 of 17 tasks
@BentsiLeviav
2
[Feature Request]: Add InsertRetryPolicy for non-successful BigQuery insertAll responses. awaiting triage io java new feature P2
#34154 opened Mar 4, 2025 by baeminbo
2 of 17 tasks
[Bug]: Unable to use S3 bucket for ReadFromSnowflake staging bucket name awaiting triage bug io P2 python
#34151 opened Mar 3, 2025 by seanhagen
2 of 17 tasks
4
[Feature Request]: Properly incorporate bulk multimap side input reads into caching. awaiting triage new feature P3
#34149 opened Mar 3, 2025 by robertwb
17 tasks
[Bug]: BigQueryIO - unknown repeated fields are merged incorrectly to payload awaiting triage bug P2
#34145 opened Mar 3, 2025 by stankiewicz
1 of 17 tasks
2
[Feature Request]: [IcebergIO] Allow users to specify a partition spec when creating tables awaiting triage io java new feature P2
#34117 opened Feb 28, 2025 by ahmedabu98
2 of 17 tasks
4
[Feature Request]: [IcebergIO] Allow users to pass table properties to be set when creating a table awaiting triage IcebergIO IcebergIO: can only be used through ManagedIO new feature P2
#34116 opened Feb 28, 2025 by ahmedabu98
17 tasks
[Feature Request]: [IcebergIO] Configure data writers to track metrics io java new feature P2
#34112 opened Feb 28, 2025 by ahmedabu98
2 of 17 tasks
2.64.0 Release
1
@Suvrat1629
8
[Bug]: Dataflow option validation fails in VSCode Jupyter notebook awaiting triage bug dataflow good first issue P2 python
#34101 opened Feb 27, 2025 by aredshift
2 of 17 tasks
1
[Feature Request]: Upgrade to Iceberg >1.7.0 and support timestamp nano types awaiting triage IcebergIO IcebergIO: can only be used through ManagedIO io java new feature P2
#34098 opened Feb 27, 2025 by ahmedabu98
2 of 17 tasks
[Bug]: Cross-language JDBC (MSSQL) - incorrect negative Integer type conversion awaiting triage bug dataflow good first issue io P2 python
#34089 opened Feb 26, 2025 by mataralhawiti
3 of 17 tasks
9
[Bug]: gprcio limitation to < 1.66 in Python is problematic bug P2 python
#34081 opened Feb 26, 2025 by potiuk
1 of 17 tasks
2.65.0 Release
@liferoad
4
[Feature Request]: Cache the BigQuery table definition instead of calling tables.get() from every worker good first issue new feature P2 python
#34076 opened Feb 26, 2025 by PraveenAkunuru
2 of 17 tasks
2
@Strikerrx01
2
[Feature Request]: Request to use BASIC enum when calling tables.get() in BigQuery good first issue new feature P2 python
#34075 opened Feb 26, 2025 by PraveenAkunuru
2 of 17 tasks
@tamannakakkar93
1
[Bug]: Iceberg sink is not resilient to worker crash bug IcebergIO IcebergIO: can only be used through ManagedIO io java P2
#34074 opened Feb 26, 2025 by ahmedabu98
2 of 17 tasks
2.64.0 Release
@ahmedabu98
1
[Task]: Remove powermock dependency awaiting triage P2 task
#34056 opened Feb 22, 2025 by Abacn
17 tasks
ProTip! Type g i on any issue or pull request to go back to the issue listing page.