@Internal public interface KubernetesArtifactUploader
Modifier and Type | Method and Description |
---|---|
void |
uploadAll(Configuration config)
Uploads all
local:// schemed artifact that is present, according to the given
configuration. |
void uploadAll(Configuration config) throws Exception
local://
schemed artifact that is present, according to the given
configuration. Any remote artifact remains as it was passed originally.
Takes the job JAR from the PipelineOptions.JARS
config and any additional
artifacts from the ArtifactFetchOptions.ARTIFACT_LIST
config. After the upload,
replaces the URIs of any local JAR in these configs to point to the remotely available one.
Requires KubernetesConfigOptions.LOCAL_UPLOAD_TARGET
to point to a valid, existing
DFS directory with read and write permissions.
config
- given Flink configurationException
- when the upload process failsCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.