You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/04/06 04:15:34 UTC
[beam] branch nightly-refs/heads/master updated (0262ee53c60 -> 9317462f73c)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 0262ee53c60 [BEAM-13519] Solve race issues when the server responds with an error before the GrpcStateClient finishes being constructed. (#17240)
add 12665d10572 [BEAM-14256] update SpEL dependency to 5.3.18.RELEASE
add 34517767417 [BEAM-14256] remove .RELEASE
add 880b10e71b9 Merge pull request #17282: [BEAM-14256] update SpEL dependency to 5.3.18
add 629f05d2e09 [BEAM-13015] Disable retries for fnapi grpc channels which otherwise defaults on. (#17243)
add 17a41790dc2 [BEAM-9649] Add region option to Mongo Dataflow test.
add 29dfe41037e Merge pull request #17284 from ibzib/BEAM-9649
add ad93728d609 Fix dependency issue causing failures
add 0c2cefffd5f Merge pull request #17283 from damccorm/users/damccorm/reportGenerator
add 7cfbc47a8b8 [BEAM-13952] Sickbay testAfterProcessingTimeContinuationTriggerUsingState (#17214)
add d8c563de574 BEAM-14235 parquetio module does not parse PEP-440 compliant Pyarrow version (#17275)
add 27b898b1e9f [BEAM-14250] Fix coder registration for types defined in __main__.
add 08431497997 Allow get_coder(None).
add 22d0bb71515 Merge pull request #17278 [BEAM-14250] Fix coder registration for types defined in __main__.
add 0f7aa9e9886 [Website] Contribution guide page indent bug fix (#17287)
add c9f9f19321d update query
add 3a6ef1d4cf6 Merge pull request #17234 from libingye816/fix-SpannerReadIT
add 82c01762ffc [BEAM-10976] Document go sdk bundle finalization (#17048)
add 9317462f73c [BEAM-13829] Expose status API from Go SDK Harness (#16957)
No new revisions were added by this update.
Summary of changes:
...ob_PostCommit_Python_MongoDBIO_Load_Test.groovy | 1 +
.../jenkins/metrics_report/requirements.txt | 4 +
CHANGES.md | 1 +
runners/flink/job-server/flink_job_server.gradle | 2 +
sdks/go.mod | 31 ++-
sdks/go.sum | 304 ++++++++++++++++-----
sdks/go/examples/snippets/04transforms.go | 17 ++
sdks/go/pkg/beam/core/runtime/harness/harness.go | 29 +-
sdks/go/pkg/beam/core/runtime/harness/init/init.go | 2 +-
.../pkg/beam/core/runtime/harness/worker_status.go | 96 +++++++
.../core/runtime/harness/worker_status_test.go | 91 ++++++
.../beam/sdk/fn/channel/ManagedChannelFactory.java | 5 +
.../beam/sdk/io/gcp/spanner/SpannerReadIT.java | 6 +-
sdks/java/io/kafka/build.gradle | 2 +-
sdks/python/apache_beam/coders/typecoders.py | 8 +
sdks/python/apache_beam/io/parquetio.py | 5 +-
website/www/site/content/en/contribute/_index.md | 63 +++--
.../content/en/documentation/programming-guide.md | 2 +-
18 files changed, 549 insertions(+), 120 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/runtime/harness/worker_status.go
create mode 100644 sdks/go/pkg/beam/core/runtime/harness/worker_status_test.go