beam icon indicating copy to clipboard operation
beam copied to clipboard

Apache Beam is a unified programming model for Batch and Streaming data processing.

Results 933 beam issues
Sort by recently updated
recently updated
newest added

This is PR is adding new field to TimerData. Noop for most of implementation apart from runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillTimerInternals.java that propagates draining information to TimerData. ------------------------ Thank you for your contribution! Follow...

runners
dataflow
direct
core
samza

Bumps [urllib3](https://github.com/urllib3/urllib3) from 2.5.0 to 2.6.0. Release notes Sourced from urllib3's releases. 2.6.0 🚀 urllib3 is fundraising for HTTP/2 support urllib3 is raising ~$40,000 USD to release HTTP/2 support and...

python
docker
dependencies

Similar to java sdk, https://github.com/apache/incubator-beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingInput.java Imported from Jira [BEAM-1069](https://issues.apache.org/jira/browse/BEAM-1069). Original Jira may contain additional context. Reported by: vikasrk.

python
core
P3
improvement
good first issue

Bumps [urllib3](https://github.com/urllib3/urllib3) from 2.5.0 to 2.6.0. Release notes Sourced from urllib3's releases. 2.6.0 🚀 urllib3 is fundraising for HTTP/2 support urllib3 is raising ~$40,000 USD to release HTTP/2 support and...

python
docker
dependencies

Bumps [urllib3](https://github.com/urllib3/urllib3) from 2.5.0 to 2.6.0. Release notes Sourced from urllib3's releases. 2.6.0 🚀 urllib3 is fundraising for HTTP/2 support urllib3 is raising ~$40,000 USD to release HTTP/2 support and...

python
docker
dependencies

When calling BigQuery's tables.get method, today, we are retrieving FULL details (which is the default). However, this is expensive and is resulting in customers hitting Quota issues. BigQuery engineering team...

stale
python
io
gcp
yaml

### What happened? We observe this error frequently during peak hours in a streaming job when Dataflow decides to autoscale workers. It looks like a race condition inside SolaceIO regarding...

stale
java
io
dataflow
bug
P2
awaiting triage

In https://github.com/apache/beam/commit/b609aab9e2bd9e8d86c8e3a511c22a4402c5704e (https://github.com/apache/beam/pull/12518), it is added to make a workaround for bug in AutoValueSchema. It seems fixed now (https://github.com/apache/beam/pull/12520), so I suggest to remove this function. Feel free to close...

java
io
kafka
Next Action: Reviewers
reassigned-reviewers

Bumps [node-forge](https://github.com/digitalbazaar/forge) from 1.3.1 to 1.3.2. Changelog Sourced from node-forge's changelog. 1.3.2 - 2025-11-25 Security HIGH: ASN.1 Validator Desynchronization An Interpretation Conflict (CWE-436) vulnerability in node-forge versions 1.3.1 and below...

dependencies
Next Action: Reviewers
typescript
javascript
reassigned-reviewers

Bumps [com.gradleup.shadow:shadow-gradle-plugin](https://github.com/GradleUp/shadow) from 8.3.8 to 9.3.0. Release notes Sourced from com.gradleup.shadow:shadow-gradle-plugin's releases. 9.3.0 Added Add PatternFilterableResourceTransformer to simplify pattern based ResourceTransformers. (#1849) Expose patternSet of ServiceFileTransformer as public. (#1849) Expose...

build
dependencies