Õâ¸ö´úÂëflink 1.5¿ÉÒÔµ÷Óà jars/uploadÉÏ´«jar°ü¡£É¶Çé¿ö £¿

Õâ¸ö´úÂëʾÀýչʾÁËÈçºÎÔÚ Flink 1.5 Öе÷Óà jars/upload ÉÏ´« jar °ü¡£¾ßÌåÀ´Ëµ，ËüʹÓÃÁË Flink µÄ FileSystem ÀàÀ´·ÃÎʱ¾µØÎļþϵͳ，²¢Ê¹Óà uploadJar ·½·¨½«Ö¸¶¨µÄ jar °üÉÏ´«µ½ Flink ¼¯ÈºÖеÄÖ¸¶¨Â·¾¶¡£

ÒÔÏÂÊÇ´úÂëʾÀý：

import org.apache.flink.api.common.JobExecutionResult;
import org.apache.flink.client.program.ClusterClient;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.runtime.jobgraph.JobGraph;
import org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster;

import java.io.File;
import java.net.URI;
import java.util.Collections;

public class FlinkUploadJarExample {
    public static void main(String[] args) throws Exception {
        // ´´½¨±¾µØ Flink ¼¯Èº
        LocalFlinkMiniCluster miniCluster = new LocalFlinkMiniCluster();
        miniCluster.start();

        // »ñÈ¡ Flink ¼¯Èº¿Í»§¶Ë
        ClusterClient<?> client = miniCluster.getClusterClient();

        // ´´½¨×÷ҵͼ
        JobGraph jobGraph = createJobGraph();

        // ÉÏ´« jar °üµ½ Flink ¼¯Èº
        URI jarUri = client.uploadJar(new File("path/to/your/jar/file.jar"));

        // ÉèÖÃ×÷ÒµÒÀÀµµÄ jar °ü
        jobGraph.getJobConfiguration().setString(org.apache.flink.configuration.ConfigOptions.JOB_MANAGER_SHARED_JARS, jarUri.toString());

        // Ìá½»×÷Òµ²¢µÈ´ý½á¹û
        JobExecutionResult result = client.submitJob(jobGraph);

        // ¹Ø±Õ Flink ¼¯Èº¿Í»§¶ËºÍ±¾µØ¼¯Èº
        client.close();
        miniCluster.stop();
    }

    private static JobGraph createJobGraph() {
        // ÔÚÕâÀï´´½¨ÄãµÄ Flink ×÷ҵͼ
        // ...
        return null; // ·µ»Ø´´½¨ºÃµÄ×÷ҵͼ
    }
}

Çë×¢Òâ，ÄãÐèÒª½« "path/to/your/jar/file.jar" Ì滻ΪÄãÒªÉÏ´«µÄ jar °üµÄʵ¼Ê·¾¶¡£´ËÍâ，Ä㻹ÐèҪʵÏÖ createJobGraph ·½·¨À´´´½¨Äã×Ô¼ºµÄ Flink ×÷ҵͼ¡£