fix 例子

Author: 胡贵

README.md

@@ -110,7 +110,6 @@ LTS 轻量级分布式任务调度框架(Light Task Schedule)
     jobClient.setClusterName("test_cluster");
     jobClient.setRegistryAddress("zookeeper://127.0.0.1:2181");
     // jobClient.setRegistryAddress("redis://127.0.0.1:6379");
-    jobClient.setJobInfoSavePath("xx");
     // 提交任务
     Job job = new Job();
     job.setTaskId("3213213123");

data/mongo/mongo.md

@@ -3,20 +3,14 @@
 
 use job;
 db.createCollection("JobPo");
-db.addUser("lts", "lts");
-db.auth("lts", "lts");
 db.JobPo.ensureIndex({"jobId":1},{unique:true});
 db.JobPo.ensureIndex({"taskTrackerNodeGroup":1, "taskId":1},{unique:true});
 db.JobPo.ensureIndex({"taskTrackerIdentity":1});
 db.JobPo.ensureIndex({"triggerTime":1, "priority":1, "gmtCreate": 1});
 db.JobPo.ensureIndex({"isRunning":1});
 db.JobPo.ensureIndex({"taskTrackerNodeGroup":1, "isRunning":1, "triggerTime":1});
 
-
 db.createCollection("JobLogPo");
-db.addUser("lts", "lts");
-db.auth("lts", "lts");
-
 db.JobLogPo.ensureIndex({"jobId":1});
 db.JobLogPo.ensureIndex({"submitNodeGroup":1, "taskId":1});
 db.JobLogPo.ensureIndex({"taskTrackerIdentity":1});
@@ -27,8 +21,5 @@ db.JobLogPo.ensureIndex({"timestamp":1});
 db.JobLogPo.ensureIndex({"taskId":1});
 
 db.createCollection("JobFeedbackPo");
-db.addUser("lts", "lts");
-db.auth("lts", "lts");
-
 db.JobFeedbackPo.ensureIndex({"id":1});
 db.JobFeedbackPo.ensureIndex({"gmtCreated":1});

job-example/src/main/java/com/lts/job/example/api/JobClientTest.java

@@ -26,7 +26,6 @@ public static void main(String[] args) throws IOException {
         jobClient.setJobFinishedHandler(new JobFinishedHandlerImpl());
         jobClient.addMasterChangeListener(new MasterChangeListenerImpl());
         jobClient.setLoadBalance("consistenthash");
-        jobClient.setJobInfoSavePath("xx");
         jobClient.start();
 
         JobClientTest jobClientTest = new JobClientTest();