beam
beam copied to clipboard
apache
Apache Beam is a unified programming model for Batch and Streaming data processing.
The PostCommit Python Xlang Gcp Direct is failing over 50% of the time. Please visit https://github.com/apache/beam/actions/workflows/beam_PostCommit_Python_Xlang_Gcp_Direct.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=2&var-Workflow=PostCommit%20Python%20Xlang%20Gcp%20Direct
![github-actions[bot] avatar](https://avatars.githubusercontent.com/in/15368?v=4 "github-actions[bot] avatar"){kind=avatar}
To improve the performance of the query for GetUnfinishedMinWatermark, we can add a filter to the query. Note that the query run on a cache to refresh every 1s. We...
V1 change stream can use null end timestamp for the query, however V2 the end timestamp of the query should be NOT NULL, and should be at most 30 mins...
https://github.com/apache/beam/issues/35030 - Phase 2 ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [x] Mention the appropriate issue in your...
**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: - [ ]...
This test seems to consistently flake when running against prism in https://github.com/apache/beam/pull/34612 - seeing if it will flake here with just this test on prism. I've tried reproing locally and...
**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: - [ ]...
Tried uncommenting the entire Kafka test to see if it ran with self hosted runner, but still hits that timeout input queue. So just uncommenting out the WriteToKafka portion. https://github.com/apache/beam/issues/35272...
### What needs to happen? https://github.com/apache/beam/issues/35198 ### Issue Priority Priority: 2 (default / most normal work should be filed as P2) ### Issue Components - [ ] Component: Python SDK...