beam
beam copied to clipboard
Apache Beam is a unified programming model for Batch and Streaming data processing.
### What happened? In the Tour of beam : Python . Additional Outputs section the code is written in go instead of python. https://tour.beam.apache.org/tour/python/core-transforms/additional-outputs ### Issue Priority Priority: 2 (default...
Update the Beam site pages with the 2.59.0 release, targeted for 2024-08-28. ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:...
The Clean Up Prebuilt SDK Images is failing over 80% of the time Please visit https://github.com/apache/beam/actions/workflows/beam_CleanUpPrebuiltSDKImages.yml?query=is%3Afailure+branch%3Amaster to see the logs.
### What happened? Go to https://beam.apache.org/get-started/quickstart-java/#optional-convert-from-maven-to-gradle At step 4. when you add the script to the build script (supposed to be in Kotlin DSL) You will get a gradle error...
### What would you like to happen? Add script to run Word-Count with Gradle for PowerShell ### Issue Priority Priority: 2 (default / most feature requests should be filed as...
### What needs to happen? The output of this task is an extension of PipelineRunner to submit Java SDK Pipeline jobs to Prism. Dependencies: - [x] #31402 - [x] #31792...
### What would you like to happen? Is it possible for the python sdk and image to support protobuf 5+? I have a project that consumes protobuf files generated with...
### What needs to happen? If a Beam dependency has a flexible upper bound, users will download the most recent compatible version of a dependency at sdk installation time. Overtime,...
### What happened? BigQueryIO's CDC ingestion requires usage of RowMutationInformation class. This class was two pairs of methods to return the change sequence number. The recently deprecated pair, "public static...
### What would you like to happen? The current implementation recreates a TableRow from the protobuf message when withPropagateSuccessfulStorageApiWrites(true) is used. For tables with a large number of rows this...