Merge pull request #3 from bsidhom/python-url

Hard-code a new python url
aljoscha · Mar 12, 2018 · 92cdd00 · 92cdd00
2 parents dd328ef + 61c4037
commit 92cdd00
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ava/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunction.java b/...ava/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunction.java
@@ -79,7 +79,7 @@ public void open(Configuration parameters) throws Exception {
         .build();
     RunnerApi.Environment environment = RunnerApi.Environment.newBuilder()
         // TODO: Set this from transform metadata.
-        .setUrl("gcr.io/google.com/hadoop-cloud-dev/beam/java")
+        .setUrl("gcr.io/google.com/hadoop-cloud-dev/beam/python")
         .build();
     ArtifactSource artifactSource =
         CachedArtifactSource.createDefault(getRuntimeContext().getDistributedCache());