Hard-code a new python url

aljoscha · Mar 12, 2018 · 61c4037 · 61c4037
1 parent dd328ef
commit 61c4037
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());