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/05 04:35:51 UTC
[beam] branch nightly-refs/heads/master updated (8d5ca41992b -> 0262ee53c60)
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 8d5ca41992b [BEAM-14143] Simplifies the ExternalPythonTransform API (#17101)
add b3ac9f24595 Update python container version
add 6efb6d1346c Merge branch 'master' of github.com:apache/beam into update-python
add 1fa505a9b3c Merge branch 'master' of github.com:apache/beam into update-python
add 4213f9edfeb Merge pull request #17245 from kileys/update-python
add 47f465ddfbf Add --dataflowServiceOptions=enable_prime to useUnifiedWorker conditions (#17213)
add e4f37d22812 Add self-descriptive message for expected errors.
add 2583cd466f7 Merge pull request #17254 from ibzib/red-herring
add 11cccb4da73 [BEAM-10529] nullable xlang coder (#16923)
add c7a06b1f7f3 Fix go fmt break in core/typex/special.go (#17266)
add ad1d3cbc1cd [BEAM-8970] Add docs to run wordcount example on portable Spark Runner
add ba5d5d47f40 [BEAM-8970] Add period to end of sentence
add 384e38105b8 Merge pull request #17233 from benWize/BEAM-8970
add 70ff734d4e5 [BEAM-5436] Add doc page on Go cross compilation. (#17256)
add 0c34a7da7be Pr-bot Don't count all reviews as approvals (#17269)
add 483cbbc38f4 Fix postcommits (#17263)
add ff81afdc4ad [BEAM-14241] Address staticcheck warnings in boot.go (#17264)
add 747e94b62d2 [BEAM-14157] GrpcWindmillServer: Use stream specific boolean to do client closed check (#17191)
add d4f59c71562 [BEAM-10582] Allow (and test) pyarrow 7 (#17229)
add 0262ee53c60 [BEAM-13519] Solve race issues when the server responds with an error before the GrpcStateClient finishes being constructed. (#17240)
No new revisions were added by this update.
Summary of changes:
...ommit_CrossLanguageValidatesRunner_Flink.groovy | 1 -
.../beam/model/fnexecution/v1/standard_coders.yaml | 12 +
.../pipeline/src/main/proto/beam_runner_api.proto | 16 +-
.../core/construction/CoderTranslators.java | 17 ++
.../core/construction/ModelCoderRegistrar.java | 3 +
.../runners/core/construction/ModelCoders.java | 5 +-
.../core/construction/CoderTranslationTest.java | 2 +
.../beam/runners/dataflow/DataflowRunner.java | 4 +-
.../worker/windmill/GrpcWindmillServer.java | 11 +-
.../worker/windmill/GrpcWindmillServerTest.java | 272 +++++++++++++++------
.../runners/fnexecution/wire/CommonCoderTest.java | 17 +-
scripts/ci/pr-bot/processNewPrs.ts | 4 +-
sdks/go/container/boot.go | 10 +-
sdks/go/pkg/beam/core/graph/coder/coder.go | 19 +-
sdks/go/pkg/beam/core/graph/coder/coder_test.go | 61 +++++
sdks/go/pkg/beam/core/graph/coder/map.go | 32 ---
sdks/go/pkg/beam/core/graph/coder/map_test.go | 4 +-
sdks/go/pkg/beam/core/graph/coder/nil.go | 53 ++++
sdks/go/pkg/beam/core/graph/coder/nil_test.go | 98 ++++++++
sdks/go/pkg/beam/core/graph/coder/row_decoder.go | 2 +-
sdks/go/pkg/beam/core/graph/coder/row_encoder.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/coder.go | 62 +++++
sdks/go/pkg/beam/core/runtime/exec/coder_test.go | 6 +
sdks/go/pkg/beam/core/runtime/graphx/coder.go | 19 +-
sdks/go/pkg/beam/core/runtime/graphx/coder_test.go | 4 +
sdks/go/pkg/beam/core/runtime/graphx/dataflow.go | 24 ++
sdks/go/pkg/beam/core/typex/fulltype.go | 2 +
sdks/go/pkg/beam/core/typex/special.go | 3 +
sdks/go/test/integration/integration.go | 2 +
.../go/test/regression/coders/fromyaml/fromyaml.go | 13 +
.../harness/state/BeamFnStateGrpcClientCache.java | 105 +++++---
.../state/BeamFnStateGrpcClientCacheTest.java | 83 ++++---
sdks/python/apache_beam/coders/coders.py | 20 +-
.../apache_beam/coders/standard_coders_test.py | 4 +-
sdks/python/apache_beam/coders/typecoders.py | 3 +-
sdks/python/apache_beam/coders/typecoders_test.py | 7 +
.../apache_beam/runners/dataflow/internal/names.py | 4 +-
.../portability/fn_api_runner/fn_runner_test.py | 6 +-
sdks/python/apache_beam/typehints/typehints.py | 21 +-
.../python/apache_beam/typehints/typehints_test.py | 8 +
sdks/python/setup.py | 2 +-
sdks/python/test-suites/tox/py38/build.gradle | 4 +
sdks/python/tox.ini | 3 +-
.../site/content/en/documentation/runners/spark.md | 76 ++++++
.../en/documentation/sdks/go-cross-compilation.md | 76 ++++++
.../www/site/content/en/documentation/sdks/go.md | 6 +-
.../layouts/partials/section-menu/en/sdks.html | 2 +
47 files changed, 1000 insertions(+), 210 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/graph/coder/nil.go
create mode 100644 sdks/go/pkg/beam/core/graph/coder/nil_test.go
create mode 100644 website/www/site/content/en/documentation/sdks/go-cross-compilation.md