beam
beam copied to clipboard
apache
Apache Beam is a unified programming model for Batch and Streaming data processing.
### What happened? Seems like Go x-lang integration tests (for example, DebeziumIO, JDBCIO) are flaky. For example, https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/4702/consoleFull 10:26:17 2023/10/10 17:25:26 🐳 Terminating container: 82fa13ab9230 10:26:17 containers.go:100: error terminating container:...
### What happened? Action suite has never succeeded. https://github.com/apache/beam/actions/workflows/beam_PostCommit_Java_Sickbay.yml?query=is%3Asuccess Seems to be flink related at present, but this could just be a poorly formulated "sickbay suite" since those are typically...
### What happened? The following job has been failing in Jenkins for a long time: - https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_XVR_GoUsingJava_Dataflow/
### What happened? Dataflow is making DataSampling FnAPI requests even when DataSampling is disabled. But since the feature wasn't enabled, the Go SDK isn't initialzing the datasampler, leading to nil...
### What needs to happen? Current project summary is a very short paragraph: https://pypi.org/project/apache-beam/. We could add more content and useful pointers to that page, perhaps similar to https://pypi.org/project/scipy/. ###...
https://ci-beam.apache.org/job/beam_PreCommit_Python_Cron/ There are a variety of tests failing, and each run has a different failure. However, after looking through it seems that test_pardo_large_input is one of the more commonly failing...
Both AfterAll and AfterAny should complete after firing, but they base their logic on the subtriggers, but they instead only finish if all the fired subtriggers or any of the...
### What happened? I am writing a pipeline to consume message from pubsub, do some validation, transform and sink to bigquery. I need to load some data from external api...
Currenlty, PerWorkerHistograms are in a Map that's keyed by `KV`. After this change the map they're stored in will be Keyed by `MetricName`. Computing a hash/equality for the `KV` object...
------------------------ 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:...
