Package org.apache.flink.kubernetes.artifact

Interface KubernetesArtifactUploader

  • All Known Implementing Classes:
    DefaultKubernetesArtifactUploader
    @Internal
public interface KubernetesArtifactUploader
    Local artifact uploader for Kubernetes programs.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void uploadAll​(org.apache.flink.configuration.Configuration config)
      Uploads all local:// schemed artifact that is present, according to the given configuration.

    • Method Detail

      • uploadAll

        void uploadAll​(org.apache.flink.configuration.Configuration config)
        throws Exception
        Uploads all 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.

        Parameters:
        config - given Flink configuration
        Throws:
        Exception - when the upload process fails