java 使用SparkLauncher提交spark任务运行在minio上面的jar包

要在Java中使用SparkLauncher提交Spark任务并运行在MinIO上面的JAR包，可以按照以下步骤操作：

1. 首先，需要导入以下依赖：

<dependency>
    <groupId>org.apache.spark</groupId>
    <artifactId>spark-core_2.12</artifactId>
    <version>3.1.2</version>
</dependency>
<dependency>
    <groupId>org.apache.spark</groupId>
    <artifactId>spark-launcher_2.12</artifactId>
    <version>3.1.2</version>
</dependency>
<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>8.0.11</version>
</dependency>

2. 接下来，需要创建一个SparkLauncher实例，设置Spark应用程序的相关参数，如下所示：

SparkLauncher launcher = new SparkLauncher()
    .setAppName("MyApp")
    .setSparkHome("/path/to/spark/home")
    .setMaster("spark://host:port")
    .setAppResource("s3a://bucket/path/to/myapp.jar")
    .setMainClass("com.myapp.Main")
    .addAppArgs("arg1", "arg2")
    .setConf(SparkLauncher.DRIVER_MEMORY, "1g")
    .setConf("spark.executor.instances", "2");

其中，setAppName()设置应用程序名称，setSparkHome()设置Spark安装路径，setMaster()设置Spark集群的Master节点地址，setAppResource()设置应用程序Jar包的路径，setMainClass()设置应用程序的入口类，addAppArgs()设置应用程序所需的参数，setConf()设置Spark配置项。

3. 然后，需要将MinIO的access key和secret key设置为环境变量，如下所示：

System.setProperty("aws.accessKeyId", "my_access_key");
System.setProperty("aws.secretKey", "my_secret_key");

4. 接下来，需要创建一个MinIO Client实例，并使用它来上传应用程序Jar包到MinIO存储桶中，如下所示：

MinioClient client = MinioClient.builder()
    .endpoint("http://minio-host:9000")
    .credentials("my_access_key", "my_secret_key")
    .build();
client.uploadObject(
    UploadObjectArgs.builder()
        .bucket("my-bucket")
        .object("path/to/myapp.jar")
        .filename("/path/to/myapp.jar")
        .build());

其中，endpoint()设置MinIO服务的地址，credentials()设置访问MinIO服务的凭证，uploadObject()将本地Jar包上传到MinIO存储桶中。

5. 最后，可以使用SparkLauncher的start()方法启动Spark应用程序，如下所示：

LauncherApps.submit(launcher);

其中，LauncherApps是SparkLauncher的静态类，submit()方法用于提交Spark应用程序。

以上就是在Java中使用SparkLauncher提交Spark任务并运行在MinIO上面的JAR包的步骤。