(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}