This is an automated email from the ASF dual-hosted git repository.
riteshghorse pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 07f32a26005 Add message for new prism users. (#27886)
add 1b2c38d9ada [prism] Avoid prism locking on data send on ProcessBundle
failure. (#27887)
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/runners/prism/internal/execute.go | 7 +++---
.../beam/runners/prism/internal/jobservices/job.go | 3 ++-
.../prism/internal/jobservices/management.go | 2 +-
sdks/go/pkg/beam/runners/prism/internal/stage.go | 25 +++++++++++++++-------
.../beam/runners/prism/internal/worker/bundle.go | 14 ++++++++----
.../runners/prism/internal/worker/bundle_test.go | 3 ++-
.../runners/prism/internal/worker/worker_test.go | 4 ++--
7 files changed, 38 insertions(+), 20 deletions(-)
