You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lo...@apache.org on 2022/06/14 16:37:31 UTC

[beam] branch master updated (6cfcc9d98bd -> 091c05ce4b6)

This is an automated email from the ASF dual-hosted git repository.

lostluck pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 6cfcc9d98bd [BEAM-14036] Read Configuration for Pub/Sub SchemaTransform (#17730)
     add 091c05ce4b6 [Go SDK] Add more info to Worker Status API (#21776)

No new revisions were added by this update.

Summary of changes:
 sdks/go/container/boot.go                          |  2 +-
 sdks/go/pkg/beam/core/metrics/store.go             | 50 ++++++++++++++++
 sdks/go/pkg/beam/core/runtime/harness/harness.go   | 52 ++++++++---------
 sdks/go/pkg/beam/core/runtime/harness/init/init.go |  3 +-
 .../core/runtime/harness/statecache/statecache.go  |  7 +++
 .../pkg/beam/core/runtime/harness/worker_status.go | 66 +++++++++++++++++++---
 .../core/runtime/harness/worker_status_test.go     |  6 +-
 sdks/go/test/integration/wordcount/wordcount.go    |  3 +-
 8 files changed, 149 insertions(+), 40 deletions(-)