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 697a1d1 Merge pull request #5508: [SQL] Add integration tests for
BigQuery writes
add 6118222 proto changes to support artifact_staging_id
add 5c2c092 Doc changes
add 845e8c5 Renaming artifact_staging_id to staging_session_token
add d0955c2 Fixing python code for staging_session_token proto changes
add 9072088 Fixing java code for staging_session_token proto changes
add 6df43d7 Go proto update
add 6f23949 Code review comments fixes
new be6185f Merge pull request #5489: [BEAM-4290] proto changes to
support staging_session_token
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_artifact_api.proto | 19 +-
.../src/main/proto/beam_job_api.proto | 6 +-
.../core/construction/ArtifactServiceStager.java | 6 +-
.../InMemoryArtifactStagerService.java | 2 +-
.../LocalFileSystemArtifactStagerService.java | 2 +-
.../portable/job/ReferenceRunnerJobService.java | 3 +
.../LocalFileSystemArtifactStagerServiceTest.java | 18 +-
.../jobsubmission/InMemoryJobService.java | 3 +
.../runners/reference/testing/TestJobService.java | 1 +
sdks/go/gogradle.lock | 2 +-
sdks/go/pkg/beam/artifact/materialize_test.go | 6 +-
sdks/go/pkg/beam/artifact/server_test.go | 2 +-
sdks/go/pkg/beam/artifact/stage.go | 7 +-
.../beam/model/fnexecution_v1/beam_fn_api.pb.go | 1572 ++++++++---
.../model/fnexecution_v1/beam_provision_api.pb.go | 255 +-
.../model/jobmanagement_v1/beam_artifact_api.pb.go | 567 +++-
.../beam/model/jobmanagement_v1/beam_job_api.pb.go | 604 +++--
.../beam/model/pipeline_v1/beam_runner_api.pb.go | 2750 +++++++++++++++-----
sdks/go/pkg/beam/model/pipeline_v1/endpoints.pb.go | 80 +-
.../model/pipeline_v1/standard_window_fns.pb.go | 174 +-
.../runners/portability/local_job_service.py | 5 +-
.../runners/portability/portable_stager.py | 20 +-
.../runners/portability/portable_stager_test.py | 18 +-
23 files changed, 4706 insertions(+), 1416 deletions(-)
--
To stop receiving notification emails like this one, please contact
[email protected].
