beam

beam copied to clipboard

docs: modernize py dependencies docs and example

1

Fixes #31431 A more common approach to packaging Python package is leveraging pyproject.toml files and having a src directory (instead of a flat directory). This change intends to update the...

nitobuendia

[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: -...

jrmccluskey

Document dynamic destination key should be unique over the pipeline

2

Document an existing issue #32335 **Please** add a meaningful description for your change here ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly...

Abacn

Add JobServerOption for `--jar_cache_dir`

1

**Please** add a meaningful description for your change here Pass custom cache dir to prevent `PermissionError: [Errno 13] Permission denied: '/home/.apache_beam'` ------------------------ Thank you for your contribution! Follow this checklist...

s21lee

Kafka poll interval

2

**Please** add a meaningful description for your change here ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ]...

Naireen

The PreCommit GoPortable job is flaky

4

The PreCommit GoPortable is failing over 50% of the time. Please visit https://github.com/apache/beam/actions/workflows/beam_PreCommit_GoPortable.yml?query=is%3Afailure+branch%3Amaster to see all failed workflow runs. See also Grafana statistics: http://metrics.beam.apache.org/d/CTYdoxP4z/ga-post-commits-status?orgId=1&viewPanel=10&var-Workflow=PreCommit%20GoPortable

github-actions[bot]

Add predicate to control which columns are propagated when propagating successful rows

2

reuvenlax

Integrate direct path

5

- Add correct shutdown mechanics - remove deadline from direct path streaming RPCs - consume worker metadata more efficient (i.e remove polling) R: @scwhittle ------------------------ Thank you for your contribution!...

m-trieu

[YAML] Better errors for unconsumed error outputs.

2

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

robertwb

Fix writing raw messages to pubsub

1

Writing raw messages to pubsub in Beam YAML writes a string object instead of encoded bytes (which is the expected type) - this PR fixes raw messages to instead be...

Polber