(2) 新建一个java类： Demo.java

提交作业需要指定集群ID或者使用匿名集群参数。本例子使用匿名集群方式进行。匿名集群需要配置2个参数, 其中:

• 可用的镜像ID, 可以使用系统提供的Image，也可以自行制作镜像, 请看使用镜像。
• 实例规格（InstanceType,实例类型），请看 目前支持类型。

在 OSS 中创建存储StdoutRedirectPath(程序输出结果)和StderrRedirectPath(错误日志)的文件路径，本例中创建的路径为

oss://your-bucket/log-count/logs/

• 如需运行本例子，请按照上文所述的变量获取以及与上文对应的您的OSS路径对程序中注释中的变量进行修改。

Java SDK 提交程序模板如下，程序中具体参数含义请参照 SDK接口说明。

Demo.java:

/*
* IMAGE_ID：ECS镜像，由上文所述获取
* INSTANCE_TYPE: 实例类型，由上文所述获取
* REGION_ID：区域为青岛/杭州，目前只有青岛开通，此项需与上文OSS存储worker的bucket地域一致
* ACCESS_KEY_ID: AccessKeyId可以由上文所述获取
* ACCESS_KEY_SECRET: AccessKeySecret可以由上文所述获取
* WORKER_PATH：由上文所述打包上传的worker的OSS存储路径
* LOG_PATH：错误反馈和task输出的存储路径，logs文件需事先自行创建
 */
 import com.aliyuncs.batchcompute.main.v20151111.*;
 import com.aliyuncs.batchcompute.model.v20151111.*;
 import com.aliyuncs.batchcompute.pojo.v20151111.*;
 import com.aliyuncs.exceptions.ClientException;
 import java.util.ArrayList;
 import java.util.List;
 public class Demo {
     static String IMAGE_ID = "img-ubuntu";;  //这里填写您的 ECS 镜像ID
     static String INSTANCE_TYPE = "bcs.a2.large"; //根据region填写合适的InstanceType
     static String REGION_ID = "cn-shenzhen";   //这里填写region
     static String ACCESS_KEY_ID = "";  //"your-AccessKeyId";   这里填写您的AccessKeyId
     static String ACCESS_KEY_SECRET = ""; //"your-AccessKeySecret";    这里填写您的AccessKeySecret
     static String WORKER_PATH = ""; //"oss://your-bucket/log-count/worker.tar.gz"; //   这里填写您上传的worker.tar.gz的OSS存储路径
     static String LOG_PATH = ""; // "oss://your-bucket/log-count/logs/"; //   这里填写您创建的错误反馈和task输出的OSS存储路径
     static String MOUNT_PATH = ""; // "oss://your-bucket/log-count/";
     public static void main(String[] args){
         /** 构造 BatchCompute 客户端 */
         BatchCompute client = new BatchComputeClient(REGION_ID, ACCESS_KEY_ID, ACCESS_KEY_SECRET);
         try{
             /** 构造 Job 对象 */
             JobDescription jobDescription = genJobDescription();
             //创建Job
             CreateJobResponse response = client.createJob(jobDescription);
             //创建成功后，返回jobId
             String jobId = response.getJobId();
             System.out.println("Job created success, got jobId: "+jobId);
             //查询job状态
             GetJobResponse getJobResponse = client.getJob(jobId);
             Job job = getJobResponse.getJob();
             System.out.println("Job state:"+job.getState());
         } catch (ClientException e) {
             e.printStackTrace();
             System.out.println("Job created failed, errorCode:"+ e.getErrCode()+", errorMessage:"+e.getErrMsg());
         }
     }
     private static JobDescription genJobDescription(){
         JobDescription jobDescription = new JobDescription();
         jobDescription.setName("java-log-count");
         jobDescription.setPriority(0);
         jobDescription.setDescription("log-count demo");
         jobDescription.setJobFailOnInstanceFail(true);
         jobDescription.setType("DAG");
         DAG taskDag = new DAG();
         /** 添加 split task */
         TaskDescription splitTask =  genTaskDescription();
         splitTask.setTaskName("split");
         splitTask.setInstanceCount(1);
         splitTask.getParameters().getCommand().setCommandLine("java -jar batchcompute-job-log-count-1.0-SNAPSHOT-Split.jar");
         taskDag.addTask(splitTask);
         /** 添加 count task */
         TaskDescription countTask =  genTaskDescription();
         countTask.setTaskName("count");
         countTask.setInstanceCount(3);
         countTask.getParameters().getCommand().setCommandLine("java -jar batchcompute-job-log-count-1.0-SNAPSHOT-Count.jar");
         taskDag.addTask(countTask);
         /** 添加 merge task */
         TaskDescription mergeTask =  genTaskDescription();
         mergeTask.setTaskName("merge");
         mergeTask.setInstanceCount(1);
         mergeTask.getParameters().getCommand().setCommandLine("java -jar batchcompute-job-log-count-1.0-SNAPSHOT-Merge.jar");
         taskDag.addTask(mergeTask);
         /** 添加Task依赖:  split-->count-->merge  */
         List<String> taskNameTargets = new ArrayList();
         taskNameTargets.add("merge");
         taskDag.addDependencies("count", taskNameTargets);
         List<String> taskNameTargets2 = new ArrayList();
         taskNameTargets2.add("count");
         taskDag.addDependencies("split", taskNameTargets2);
         //dag
         jobDescription.setDag(taskDag);
         return jobDescription;
     }
     private static TaskDescription genTaskDescription(){
         AutoCluster autoCluster = new AutoCluster();
         autoCluster.setInstanceType(INSTANCE_TYPE);
         autoCluster.setImageId(IMAGE_ID);
         //autoCluster.setResourceType("OnDemand");
         TaskDescription task = new TaskDescription();
         //task.setTaskName("Find");
         //打包上传的作业的OSS全路径
         Parameters p = new Parameters();
         Command cmd = new Command();
         //cmd.setCommandLine("");
         //打包上传的作业的OSS全路径
         cmd.setPackagePath(WORKER_PATH);
         p.setCommand(cmd);
         //错误反馈存储路径
         p.setStderrRedirectPath(LOG_PATH);
         //最终结果输出存储路
         p.setStdoutRedirectPath(LOG_PATH);
         task.setParameters(p);
         task.addInputMapping(MOUNT_PATH, "/home/input");
         task.addOutputMapping("/home/output",MOUNT_PATH);
         task.setAutoCluster(autoCluster);
         //task.setClusterId(clusterId);
         task.setTimeout(30000); /* 30000 秒*/
         task.setInstanceCount(1); /** 使用1个实例来运行 */
         return task;
     }
 }

Job created success, got jobId: job-01010100010192397211
Job state:Waiting

{"INFO": 2460, "WARN": 2448, "DEBUG": 2509, "ERROR": 2583}