This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from edfd894 Merge pull request #8654: [BEAM-6429] side-input type
coercion for multimaps
add 23714a3 Attempt to fix lots of URNs.
add 34c1511 Fix spotless errors
add c79f879 Update Python Dataflow precommit to use worker jar built
locally
new 064be0e [BEAM-7387] Attempt to fix lots of URNs to follow common
pattern.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
model/pipeline/src/main/proto/beam_runner_api.proto | 14 +++++++-------
.../beam/runners/core/construction/CoderTranslation.java | 2 +-
.../beam/runners/core/construction/CombineTranslation.java | 2 +-
.../runners/core/construction/ExternalTranslation.java | 2 +-
.../beam/runners/core/construction/ParDoTranslation.java | 7 +++----
.../beam/runners/core/construction/ReadTranslation.java | 4 ++--
.../runners/core/construction/WindowIntoTranslation.java | 2 +-
.../runners/core/construction/WriteFilesTranslation.java | 3 +--
.../org/apache/beam/runners/direct/DirectGroupByKey.java | 4 ++--
.../org/apache/beam/runners/direct/MultiStepCombine.java | 4 ++--
.../beam/runners/direct/ParDoMultiOverrideFactory.java | 3 +--
.../beam/runners/direct/TestStreamEvaluatorFactory.java | 2 +-
.../apache/beam/runners/direct/ViewOverrideFactory.java | 3 +--
.../worker/graph/CreateExecutableStageNodeFunction.java | 6 +++---
.../dataflow/worker/graph/RegisterNodeFunction.java | 6 +++---
sdks/go/pkg/beam/core/runtime/exec/translate.go | 4 ++--
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 4 ++--
sdks/go/pkg/beam/model/pipeline_v1/beam_runner_api.pb.go | 10 +++++-----
sdks/go/pkg/beam/runners/session/session.go | 4 ++--
.../org/apache/beam/sdk/fn/data/RemoteGrpcPortRead.java | 2 +-
.../org/apache/beam/sdk/fn/data/RemoteGrpcPortWrite.java | 2 +-
.../beam/fn/harness/control/ProcessBundleHandler.java | 4 ++--
.../apache/beam/fn/harness/BoundedSourceRunnerTest.java | 4 ++--
.../beam/fn/harness/control/ProcessBundleHandlerTest.java | 4 ++--
.../beam/fn/harness/control/RegisterHandlerTest.java | 4 ++--
sdks/python/apache_beam/runners/worker/bundle_processor.py | 10 +++++-----
sdks/python/test-suites/dataflow/build.gradle | 7 ++++++-
website/src/contribute/runner-guide.md | 4 ++--
28 files changed, 64 insertions(+), 63 deletions(-)
