This is an automated email from the ASF dual-hosted git repository.
jkff pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from ebdf6ba Fixes null pointer exception on empty pubsub message data
(#5016)
add 721357e Propagates artifact retrieval token in Flink runner and to
the Java harness
new 3ae2a78 Merge pull request #5676: [BEAM-4291] Propagates artifact
retrieval token in Flink runner and to the Java harness
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:
.../src/main/proto/beam_provision_api.proto | 4 +
.../beam/runners/flink/FlinkJobInvocation.java | 29 +-
.../apache/beam/runners/flink/FlinkJobInvoker.java | 3 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 3 +-
.../FlinkExecutableStageFunctionTest.java | 3 +-
.../fnexecution/jobsubmission/JobInvoker.java | 10 +-
.../runners/fnexecution/provisioning/JobInfo.java | 10 +-
sdks/go/BUILD.md | 3 +
sdks/go/container/boot.go | 2 +-
sdks/go/pkg/beam/artifact/materialize.go | 18 +-
sdks/go/pkg/beam/artifact/materialize_test.go | 63 +--
sdks/go/pkg/beam/artifact/server_test.go | 49 ++-
sdks/go/pkg/beam/artifact/stage.go | 16 +-
sdks/go/pkg/beam/artifact/stage_test.go | 22 +-
.../go/pkg/beam/model/PROTOBUF.md | 14 +-
.../beam/model/fnexecution_v1/beam_fn_api.pb.go | 370 +++++++++---------
.../model/fnexecution_v1/beam_provision_api.pb.go | 127 +++---
.../model/jobmanagement_v1/beam_artifact_api.pb.go | 68 ++--
.../beam/model/jobmanagement_v1/beam_job_api.pb.go | 72 ++--
.../beam/model/pipeline_v1/beam_runner_api.pb.go | 432 ++++++++++-----------
sdks/go/pkg/beam/model/pipeline_v1/endpoints.pb.go | 14 +-
.../model/pipeline_v1/standard_window_fns.pb.go | 32 +-
sdks/java/container/boot.go | 2 +-
sdks/python/container/boot.go | 2 +-
24 files changed, 687 insertions(+), 681 deletions(-)
copy CONTRIBUTING.md => sdks/go/pkg/beam/model/PROTOBUF.md (63%)
