This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from b0e7afb Verify schema early in ToJson and JsonToRow (#11105)
add 6fce252 [BEAM-9056] Staging artifacts from environment
add 80a2ff6 Merge pull request #10621: [BEAM-9056] Staging artifacts from
environment
No new revisions were added by this update.
Summary of changes:
.../runners/core/construction/Environments.java | 119 +++++++++--
.../runners/core/construction/SdkComponents.java | 25 ++-
.../core/construction/EnvironmentsTest.java | 19 +-
.../construction/graph/QueryablePipelineTest.java | 7 +-
.../beam/runners/portability/PortableRunner.java | 155 +++++++-------
sdks/python/apache_beam/portability/common_urns.py | 3 +
.../runners/dataflow/internal/apiclient.py | 2 +-
.../runners/portability/expansion_service.py | 2 +-
.../runners/portability/expansion_service_test.py | 3 +-
.../portability/flink_uber_jar_job_server_test.py | 1 +
.../runners/portability/local_job_service_test.py | 2 +-
.../runners/portability/portable_runner.py | 23 +-
.../runners/portability/portable_runner_test.py | 10 +-
.../apache_beam/runners/portability/stager.py | 234 +++++++++++++--------
.../apache_beam/runners/portability/stager_test.py | 57 ++---
sdks/python/apache_beam/transforms/environments.py | 108 +++++++---
.../apache_beam/transforms/environments_test.py | 3 +-
17 files changed, 499 insertions(+), 274 deletions(-)
