beam
beam copied to clipboard
apache
Apache Beam is a unified programming model for Batch and Streaming data processing.
Bumps [github.com/aws/aws-sdk-go-v2/feature/s3/manager](https://github.com/aws/aws-sdk-go-v2) from 1.13.8 to 1.17.1. Changelog Sourced from github.com/aws/aws-sdk-go-v2/feature/s3/manager's changelog. Release (2022-10-24) General Highlights Dependency Update: Updated to the latest SDK module versions Module Highlights github.com/aws/aws-sdk-go-v2/feature/ec2/imds: v1.12.19 Bug Fix:...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
### What would you like to happen? We ran into several regressions due to updates to construction schema of I/O transforms breaking transform upgrade via TransformService (from older Beam versions)....
### What needs to happen? Each time a new Flink version is supported, we need to create a new dockerhub repo prior to the release process, which involves Apache Infra...
Performance change found in the test: `sideinpts_python_batch_10gb_1kb_10workers_1000window_first_iterable` for the metric: `runtime`. For more information on how to triage the alerts, please look at `Triage performance alert issues` section of the...
![github-actions[bot] avatar](https://avatars.githubusercontent.com/in/15368?v=4 "github-actions[bot] avatar"){kind=avatar}
### What happened? PubsubMessageWithTopicCoder should return PubsubMessageWithTopicCoder while it returns PubsubMessageWithAttributesAndMessageIdCoder While investigating Dynamic Destinations on Direct runner I found out that PubsubMessageWithTopicCoder is never used and topic is lost...
The runner infrastructure typically substitutes "unknown" coders for length-prefixed bytes, but for elements going into or out of the Beam pipeline fragment we want the actual objects. Fortunately, we know...
Bumps [urllib3](https://github.com/urllib3/urllib3) from 2.2.1 to 2.2.2. Release notes Sourced from urllib3's releases. 2.2.2 🚀 urllib3 is fundraising for HTTP/2 support urllib3 is raising ~$40,000 USD to release HTTP/2 support and...
Permits to infer schemas and row conversion functions for generic classes for schema providers extending `GetterBasedSchemaProvider`, see new test cases for examples of such inference. The PR is mostly about...
This is the 4th PR for the Solace Read connector (addresses #31440). It depends on the #31541, #31539 and #31476 (root). The files that are added/modified in this PR, comparing...
### What needs to happen? This should be done after #31677 Require Build Beam with Java11+. Therefore enable to use newer gradle plugins that already dropped Java8 support. The released...