beam
https://github.com/apache/beam
Java
Apache Beam is a unified programming model for Batch and Streaming data processing.
Triage Issues!
When you volunteer to triage issues, you'll receive an email each day with a link to an open issue that needs help in this project. You'll also receive instructions on how to triage issues.
Triage Docs!
Receive a documented method or class from your favorite GitHub repos in your inbox every day. If you're really pro, receive undocumented methods or classes and supercharge your commit history.
Java not yet supported58 Subscribers
View all SubscribersAdd a CodeTriage badge to beam
Help out
- Issues
- fix: drain all producer queues in SolaceIO publishResults, not just the current bundle's producer [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT]
- [Cherrypick] fix iceberg CDC test - #39675
- [GSoC 2026] Implement TestPubsubContext for Python GCP Integration Tests
- [Task]: Go SDK portable logical type support
- fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT]
- Log the System name in more places instead of the computationId
- [Dataflow Streaming] Mark worker as unhealthy in presence of stuck commits
- Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec
- [Python] Deflake TextIO footer test
- [Python] Deflake anomaly transform tests
- Docs
- Java not yet supported