File tree Expand file tree Collapse file tree 3 files changed +0
-11
lines changed
job-example/src/main/java/com/lts/job/example/api Expand file tree Collapse file tree 3 files changed +0
-11
lines changed Original file line number Diff line number Diff line change @@ -110,7 +110,6 @@ LTS 轻量级分布式任务调度框架(Light Task Schedule)
110110 jobClient. setClusterName(" test_cluster" );
111111 jobClient. setRegistryAddress(" zookeeper://127.0.0.1:2181" );
112112 // jobClient.setRegistryAddress("redis://127.0.0.1:6379");
113- jobClient. setJobInfoSavePath(" xx" );
114113 // 提交任务
115114 Job job = new Job ();
116115 job. setTaskId(" 3213213123" );
Original file line number Diff line number Diff line change 33
44use job;
55db.createCollection("JobPo");
6- db.addUser("lts", "lts");
7- db.auth("lts", "lts");
86db.JobPo.ensureIndex({"jobId":1},{unique: true });
97db.JobPo.ensureIndex({"taskTrackerNodeGroup":1, "taskId":1},{unique: true });
108db.JobPo.ensureIndex({"taskTrackerIdentity":1});
119db.JobPo.ensureIndex({"triggerTime":1, "priority":1, "gmtCreate": 1});
1210db.JobPo.ensureIndex({"isRunning":1});
1311db.JobPo.ensureIndex({"taskTrackerNodeGroup":1, "isRunning":1, "triggerTime":1});
1412
15-
1613db.createCollection("JobLogPo");
17- db.addUser("lts", "lts");
18- db.auth("lts", "lts");
19-
2014db.JobLogPo.ensureIndex({"jobId":1});
2115db.JobLogPo.ensureIndex({"submitNodeGroup":1, "taskId":1});
2216db.JobLogPo.ensureIndex({"taskTrackerIdentity":1});
@@ -27,8 +21,5 @@ db.JobLogPo.ensureIndex({"timestamp":1});
2721db.JobLogPo.ensureIndex({"taskId":1});
2822
2923db.createCollection("JobFeedbackPo");
30- db.addUser("lts", "lts");
31- db.auth("lts", "lts");
32-
3324db.JobFeedbackPo.ensureIndex({"id":1});
3425db.JobFeedbackPo.ensureIndex({"gmtCreated":1});
Original file line number Diff line number Diff line change @@ -26,7 +26,6 @@ public static void main(String[] args) throws IOException {
2626 jobClient .setJobFinishedHandler (new JobFinishedHandlerImpl ());
2727 jobClient .addMasterChangeListener (new MasterChangeListenerImpl ());
2828 jobClient .setLoadBalance ("consistenthash" );
29- jobClient .setJobInfoSavePath ("xx" );
3029 jobClient .start ();
3130
3231 JobClientTest jobClientTest = new JobClientTest ();
You can’t perform that action at this time.
0 commit comments