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 2020/09/26 02:54:54 UTC
[beam] tag nightly-master updated (d1261ad -> 64d8c80)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from d1261ad (commit)
to 64d8c80 (commit)
from d1261ad [BEAM-6103] Enable BQ streaming insert timeouts (#12893)
add 4fc07cc Change when streaming Combine on Flink should be fired (#12931)
add bcc25f6 [BEAM-10759] Uses reader Avro schema to deserialize in KafkaIO
add a6e51a9 Merge pull request #12630: [BEAM-10759] Uses reader Avro schema to deserialize in KafkaIO
add 8c3accd Update release guide and script
add cc40a37 Merge pull request #12936 from robinyqiu/website
add 806e67d [BEAM-9616] Add RegisterDoFn (#12903)
add 3b3b86a spannerio.py doc typo fix
add 9684d86 Merge pull request #12940 from derrickqin/py-spanner-doc-fix
add 4818697 [BEAM-10975] Remove capture_output argument in sdk_container_builder (#12942)
add 3840369 [BEAM-10959] Store a fixed amount of known process bundle instructions to prevent failures due to concurrency within a runner. (#12934)
add 6175b81 [BEAM-10977] Disable codecov annotations in GH
add 64d8c80 Merge pull request #12944 from apache/aaltay-patch-1
No new revisions were added by this update.
Summary of changes:
.github/codecov.yml | 3 +
.../job_LoadTests_Combine_Flink_Python.groovy | 2 +-
release/src/main/scripts/verify_release_build.sh | 6 +-
sdks/go/pkg/beam/core/runtime/genx/genx.go | 172 +++++++++++++++
sdks/go/pkg/beam/core/runtime/genx/genx_test.go | 233 +++++++++++++++++++++
sdks/go/pkg/beam/core/runtime/symbols.go | 2 +-
sdks/go/pkg/beam/core/runtime/types_test.go | 18 +-
sdks/go/pkg/beam/forward.go | 30 ++-
sdks/go/pkg/beam/pardo_test.go | 6 +-
sdks/go/pkg/beam/transforms/stats/stats.shims.go | 151 ++++++-------
sdks/go/pkg/beam/transforms/top/top.go | 6 +-
sdks/go/pkg/beam/util/starcgenx/starcgenx.go | 163 ++++++++++++--
sdks/go/pkg/beam/util/starcgenx/starcgenx_test.go | 33 ++-
...onfluentSchemaRegistryDeserializerProvider.java | 24 ++-
...uentSchemaRegistryDeserializerProviderTest.java | 49 ++++-
.../apache_beam/io/gcp/experimental/spannerio.py | 2 +-
.../runners/portability/fn_api_runner/fn_runner.py | 14 +-
.../runners/portability/sdk_container_builder.py | 5 +-
.../apache_beam/runners/worker/sdk_worker.py | 172 ++++++++++-----
.../apache_beam/runners/worker/sdk_worker_test.py | 92 ++++++++
.../site/content/en/contribute/release-guide.md | 8 +-
21 files changed, 1015 insertions(+), 176 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/runtime/genx/genx.go
create mode 100644 sdks/go/pkg/beam/core/runtime/genx/genx_test.go