beam
beam copied to clipboard
Apache Beam is a unified programming model for Batch and Streaming data processing.
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...
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...
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.
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...
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...
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...
### 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...
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...
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...
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...