ibzib commented on a change in pull request #12803:
URL: https://github.com/apache/beam/pull/12803#discussion_r486687727
##########
File path:
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineRunner.java
##########
@@ -170,13 +169,16 @@ public static void main(String[] args) throws Exception {
Pipeline pipeline =
PortablePipelineJarUtils.getPipelineFromClasspath(baseJobName);
Struct originalOptions =
PortablePipelineJarUtils.getPipelineOptionsFromClasspath(baseJobName);
- // Flink pipeline jars distribute and retrieve artifacts via the classpath.
- PortablePipelineOptions portablePipelineOptions =
-
PipelineOptionsTranslation.fromProto(originalOptions).as(PortablePipelineOptions.class);
-
portablePipelineOptions.setRetrievalServiceType(RetrievalServiceType.CLASSLOADER);
- String retrievalToken =
PortablePipelineJarUtils.getArtifactManifestUri(baseJobName);
+ // The retrieval token is only required by the legacy artifact service,
which the Flink runner
+ // no longer uses.
+ String retrievalToken =
+ ArtifactApi.CommitManifestResponse.Constants.NO_ARTIFACTS_STAGED_TOKEN
Review comment:
I won't since this part of the API is deprecated.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
