Jack McCluskey

[Bug]: beam_PostCommit_Java_ValidatesRunner_Flink is flakes in org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState

4

### What happened? `org.apache.beam.sdk.transforms.GroupByKeyTest > org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState` tests is flaky in the Java Flink ValidatesRunner PosCommit suite. https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/testReport/org.apache.beam.sdk.transforms/GroupByKeyTest$BasicTests/testAfterProcessingTimeContinuationTriggerUsingState/ ### Issue Priority Priority: 1 ### Issue Component Component: test-failures

## Description Adds a code example for running a Dataflow RunInference pipeline using streaming, custom containers, and pubsub ## Checklist - [ ] I have followed [Sample Guidelines from AUTHORING_GUIDE.MD](https://github.com/GoogleCloudPlatform/python-docs-samples/blob/main/AUTHORING_GUIDE.md)...

Add ApplyBucketsWithInterpolation TFTransform

7

Implements the `apply_buckets_with_interpolation()` Tensorflow Transform into MLTransform. ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Mention the...

Add Gemma Flex Template example

9

## Description Adds a Gemma Flex Template example and an e2e test running on Dataflow. This code example is similar to #11284, but using a Pytorch model and deploying as...

Update Gemma on Dataflow example to pass max_length as arg

2

## Description Passes the max_length parameter to Gemma's `generate()` call through inference_args rather than having a hard-coded option. ## Checklist - [ ] I have followed [Sample Guidelines from AUTHORING_GUIDE.MD](https://github.com/GoogleCloudPlatform/python-docs-samples/blob/main/AUTHORING_GUIDE.md)...

[DO NOT MERGE] Python 3.8 deprecation workflow validation

2

PR to trigger workflows against the files post python 3.8 deprecation ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: -...

[WIP] Remove Python 3.8 targets from Actions

1

Python 3.8 is scheduled to reach EOL in October of 2024. This PR removes actions targets for 3.8 ahead of the removal of Beam support for 3.8. DO NOT MERGE...

Improve BatchElements documentation

3

Stateful BatchElements behavior (particularly the impact on throughput) was not explained. Updating the doc string to explain what the stateful option is doing as well as how the value of...

[WIP] Remove Python 3.8 Support

1

Python 3.8 is scheduled to reach EOL in October of 2024. This PR removes support for Python 3.8 ahead of the Beam 2.60.0 release, following versioning changes in #27194 and...

DO NOT MERGE ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Mention the appropriate issue in your...