This is an automated email from the ASF dual-hosted git repository.
herohde pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from cb0236c Merge pull request #5819 from [SQL] Remove unused println line
add 901242d Do not launch containers with transient semi_persistent_dir.
Fails on mac
add 190d8a9 Go-on-Flink: treat artifact staging EOF error as ok
add a5bdf53 Go-on-Flink: make transform UniqueNames _globally_ unique
add 948eac8 Go-on-Flink: remove internal java runner class hack
add 7261ef6 Go-on-Flink: fix swapped arguments in artifact staging
add c70df33 Go-on-Flink: use clearer error if the artifact retrieval
token or control client id is empty
add c9f5ae8 Go-on-Flink: fix Go to actually send worker_id gRPC header
add fda3a88 CR: Don't enforce non-empty control worker_id yet
new ca11349 [BEAM-4666] Make Go run on Flink again
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:
.../BeamFileSystemArtifactRetrievalService.java | 8 +++++++-
.../control/FnApiControlClientPoolService.java | 10 +++++++++-
.../environment/DockerEnvironmentFactory.java | 11 ++---------
sdks/go/pkg/beam/artifact/stage.go | 2 +-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 18 ++++++++++--------
sdks/go/pkg/beam/core/runtime/harness/init/init.go | 4 +++-
sdks/go/pkg/beam/options/jobopts/options.go | 4 ----
sdks/go/pkg/beam/runners/flink/flink.go | 4 ----
.../go/pkg/beam/runners/universal/runnerlib/execute.go | 2 +-
sdks/go/pkg/beam/runners/universal/runnerlib/job.go | 4 ----
sdks/go/pkg/beam/runners/universal/universal.go | 1 -
11 files changed, 33 insertions(+), 35 deletions(-)
