This is an automated email from the ASF dual-hosted git repository. herohde pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit ca11349bef3cf403912b20da03eb255d78fa9e10 Merge: cb0236c fda3a88 Author: Henning Rohde <[email protected]> AuthorDate: Thu Jun 28 15:27:19 2018 -0700 [BEAM-4666] Make Go run on Flink again .../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(-)
