beam
beam copied to clipboard
apache
Apache Beam is a unified programming model for Batch and Streaming data processing.
1. Upgrade org.apache.samza to 1.7 2. Enhance SamzaServerConfiguration to be configurable of base dir for states in order to isolate dir for different jobs to avoid state conflict. ------------------------ Thank...
As part of the migration of Pre-commit and Postcommit Jobs from Jenkins to GA in self-hosted runners, this PR contains: Migrated workflow [job-precommit-java](https://github.com/apache/beam/blob/096fb6900a747aff7ae21865d578dab8157ea379/.github/workflows/job-precommit-java.yml) The migrated workflows were removed from [.test-infra/jenkins/README.md](https://github.com/apache/beam/blob/096fb6900a747aff7ae21865d578dab8157ea379/.test-infra/jenkins/README.md)...
As part of the migration of Precommit and Postcommit Jobs from Jenkins to GA in self-hosted runners, this PR contains: - Migrated and sharded workflow [job-postcommit-go-website-publish.yml]() - Migrated and sharded...
As part of the migration of Precommit and Postcommit Jobs from Jenkins to GA in self-hosted runners, this PR contains: - Migrated and sharded workflow [job-postcommit-xvr-direct.yml]() - Migrated and sharded...
resolves #22489, resolves #22488 New solution for Playground backend - with Kubernetes and Helm New pipeline for Backend deployment: using HELM and Kubernetes ------------------------ Thank you for your contribution! Follow...
Fixes #21492 This release includes https://github.com/GoogleCloudDataproc/hadoop-connectors/pull/865 which fixes https://github.com/google/conscrypt/issues/864 . ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [...
As part of the migration of Precommit and Postcommit Jobs from Jenkins to GA in self-hosted runners, this PR contains: - Migrated and sharded workflow [job-precommit-community-metrics.yml]() - Migrated and sharded...
Fixes #23264
Improved test coverage and fix the implementation of Inject and CoGBK @lostluck #23272 ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and...
### What happened? `org.apache.beam.sdk.transforms.GroupByKeyTest > org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState` tests is flaky in the Java Flink ValidatesRunner PosCommit suite. https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/testReport/org.apache.beam.sdk.transforms/GroupByKeyTest$BasicTests/testAfterProcessingTimeContinuationTriggerUsingState/ ### Issue Priority Priority: 1 ### Issue Component Component: test-failures
