6 Pull requests merged by 5 people

• [Prism] Support BundleFinalization DoFn parameter

  #32425 merged Sep 21, 2024

• [#32498][prism] Add split / progress back off + catch-up.

  #32526 merged Sep 21, 2024

• [Python] Add a couple quality-of-life improvemenets to testing.util.assert_that

  #30771 merged Sep 21, 2024

• Rollback Bigtable throttling counter

  #32442 merged Sep 20, 2024

• Remove debug leftover

  #32524 merged Sep 20, 2024

• Include jamm as runtime dependency in expansion-service

  #32521 merged Sep 20, 2024

4 Pull requests opened by 3 people

• [WIP] Enable CDC configuration for cross language StorageWrite API usage

  #32523 opened Sep 20, 2024

• Add schrodinger logo

  #32525 opened Sep 20, 2024

• [WIP] Enable BigQuery CDC configuration for Python BigQuery sink

  #32529 opened Sep 21, 2024

• Move assert into pipeline

  #32530 opened Sep 21, 2024

5 Issues closed by 4 people

• [Bug]: How to run YAML pipeline from Python SDK rather than from command line

  #32416 closed Sep 21, 2024

• The PostCommit TransformService Direct job is flaky

  #30960 closed Sep 21, 2024

• The Python tests job is flaky

  #31006 closed Sep 21, 2024

• [Prism] Support Bundle Finalization

  #31912 closed Sep 21, 2024

• [Bug]: minimal wordcount golang example is freezeing on gcs reading

  #32498 closed Sep 21, 2024

2 Issues opened by 2 people

• [Feature Request]: vLLM model handler

  #32528 opened Sep 21, 2024

• [Feature Request]: Enable CDC configuration for cross language StorageWrite API usage

  #32527 opened Sep 20, 2024

13 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• [GCSIO] Fix internal unit test failure

  #32518 commented on Sep 21, 2024 • 5 new comments

• Rag opensearch usecase with Beam's MLTransform

  #32018 commented on Sep 21, 2024 • 3 new comments

• [yaml] Add Beam YAML Examples

  #32519 commented on Sep 20, 2024 • 1 new comment

• [Tracking Umbrella] Prism Runner areas for contribution.

  #29650 commented on Sep 21, 2024 • 0 new comments

• [Task]: Use "Distroless" Container Images to reduce potential vulnerabilities for Beam Python SDK containers

  #28991 commented on Sep 21, 2024 • 0 new comments

• `beam.CombineValues` on DataFlow runner causes ambiguous failure with python SDK

  #21432 commented on Sep 21, 2024 • 0 new comments

• [Bug]: BigqueryIO is very slow if using storage api and dynamic destination to write data to over thousand different tables with high data skew

  #32508 commented on Sep 21, 2024 • 0 new comments

• make FieldValueTypeInformation creators take a TypeDescriptor parameter

  #32081 commented on Sep 21, 2024 • 0 new comments

• [WIP] Do not merge: Vllm model handler

  #32410 commented on Sep 21, 2024 • 0 new comments

• Add various utility meta-transforms to Beam.

  #32445 commented on Sep 20, 2024 • 0 new comments

• Upgrade default kafka from 2.4.1 to 3.1.2

  #32486 commented on Sep 20, 2024 • 0 new comments

• [Python] Allow ints to be considered as floats/complexes and floats as complexes

  #32516 commented on Sep 20, 2024 • 0 new comments

• Invoke teardown when DoFn throws in portable runners

  #32522 commented on Sep 20, 2024 • 0 new comments