public class DefaultKubernetesArtifactUploader extends Object implements KubernetesArtifactUploader
KubernetesArtifactUploader
implementation.Constructor and Description |
---|
DefaultKubernetesArtifactUploader() |
Modifier and Type | Method and Description |
---|---|
void |
uploadAll(Configuration config)
Uploads all
local:// schemed artifact that is present, according to the given
configuration. |
public void uploadAll(Configuration config) throws Exception
KubernetesArtifactUploader
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.
uploadAll
in interface KubernetesArtifactUploader
config
- given Flink configurationException
- when the upload process failsCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.