Merge pull request #7 from qq254963746/develop

qq254963746 · qq254963746 · commit 688d1ce5e975 · 2015-05-20T23:51:10.000+08:00
optimize imports
diff --git a/job-admin/src/main/java/com/lts/job/web/support/AppConfigurer.java b/job-admin/src/main/java/com/lts/job/web/support/AppConfigurer.java
@@ -1,7 +1,5 @@
 package com.lts.job.web.support;
 
-import java.util.*;
-
 /**
  * @author Robert HG (254963746@qq.com) on 5/11/15.
  */
diff --git a/job-admin/src/main/java/com/lts/job/web/support/node/ZkNodeManager.java b/job-admin/src/main/java/com/lts/job/web/support/node/ZkNodeManager.java
@@ -5,12 +5,9 @@
 import com.lts.job.core.cluster.NodeType;
 import com.lts.job.core.constant.Constants;
 import com.lts.job.core.registry.NodeRegistryUtils;
-import com.lts.job.core.registry.Registry;
-import com.lts.job.core.registry.RegistryFactory;
 import com.lts.job.core.util.CollectionUtils;
-import com.lts.job.zookeeper.ZookeeperClient;
-import com.lts.job.zookeeper.zkclient.ZkClientZookeeperClient;
 import com.lts.job.web.support.AppConfigurer;
+import com.lts.job.zookeeper.ZookeeperClient;
 
 import java.util.ArrayList;
 import java.util.HashMap;
diff --git a/job-client/src/main/java/com/lts/job/client/JobClient.java b/job-client/src/main/java/com/lts/job/client/JobClient.java
@@ -12,6 +12,8 @@
 import com.lts.job.core.domain.Job;
 import com.lts.job.core.exception.JobSubmitException;
 import com.lts.job.core.exception.JobTrackerNotFoundException;
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.core.protocol.JobProtos;
 import com.lts.job.core.protocol.command.JobSubmitRequest;
 import com.lts.job.core.protocol.command.JobSubmitResponse;
@@ -22,8 +24,6 @@
 import com.lts.job.remoting.netty.NettyRequestProcessor;
 import com.lts.job.remoting.netty.ResponseFuture;
 import com.lts.job.remoting.protocol.RemotingCommand;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.util.Arrays;
 import java.util.List;
diff --git a/job-client/src/main/java/com/lts/job/client/processor/JobFinishedProcessor.java b/job-client/src/main/java/com/lts/job/client/processor/JobFinishedProcessor.java
@@ -2,15 +2,15 @@
 
 import com.lts.job.client.support.JobFinishedHandler;
 import com.lts.job.core.domain.JobResult;
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.core.protocol.JobProtos;
 import com.lts.job.core.protocol.command.JobFinishedRequest;
 import com.lts.job.core.remoting.RemotingClientDelegate;
 import com.lts.job.core.util.CollectionUtils;
 import com.lts.job.remoting.exception.RemotingCommandException;
 import com.lts.job.remoting.protocol.RemotingCommand;
 import io.netty.channel.ChannelHandlerContext;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.util.List;
 
diff --git a/job-core/src/main/java/com/lts/job/core/cluster/AbstractJobNode.java b/job-core/src/main/java/com/lts/job/core/cluster/AbstractJobNode.java
@@ -9,17 +9,16 @@
 import com.lts.job.core.listener.MasterElectionListener;
 import com.lts.job.core.listener.NodeChangeListener;
 import com.lts.job.core.listener.SelfChangeListener;
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.core.protocol.command.CommandBodyWrapper;
 import com.lts.job.core.registry.*;
 import com.lts.job.core.util.CollectionUtils;
 import com.lts.job.core.util.GenericsUtils;
 import com.lts.job.ec.EventCenterFactory;
 import com.lts.job.ec.EventInfo;
 import com.lts.job.ec.EventSubscriber;
-import com.lts.job.ec.injvm.InjvmEventCenter;
 import com.lts.job.ec.Observer;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
diff --git a/job-core/src/main/java/com/lts/job/core/cluster/AbstractServerNode.java b/job-core/src/main/java/com/lts/job/core/cluster/AbstractServerNode.java
@@ -2,8 +2,8 @@
 
 import com.lts.job.core.Application;
 import com.lts.job.core.constant.Constants;
-import com.lts.job.core.remoting.RemotingServerDelegate;
 import com.lts.job.core.factory.NamedThreadFactory;
+import com.lts.job.core.remoting.RemotingServerDelegate;
 import com.lts.job.remoting.netty.NettyRemotingServer;
 import com.lts.job.remoting.netty.NettyRequestProcessor;
 import com.lts.job.remoting.netty.NettyServerConfig;
diff --git a/job-core/src/main/java/com/lts/job/core/cluster/MasterElector.java b/job-core/src/main/java/com/lts/job/core/cluster/MasterElector.java
@@ -2,11 +2,10 @@
 
 import com.lts.job.core.Application;
 import com.lts.job.core.listener.MasterChangeListener;
-import com.lts.job.core.util.CollectionUtils;
 import com.lts.job.core.logger.Logger;
 import com.lts.job.core.logger.LoggerFactory;
+import com.lts.job.core.util.CollectionUtils;
 
-import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
 import java.util.concurrent.CopyOnWriteArrayList;
diff --git a/job-core/src/main/java/com/lts/job/core/cluster/SubscribedNodeManager.java b/job-core/src/main/java/com/lts/job/core/cluster/SubscribedNodeManager.java
@@ -3,10 +3,10 @@
 
 import com.lts.job.core.Application;
 import com.lts.job.core.listener.NodeChangeListener;
-import com.lts.job.core.util.CollectionUtils;
-import com.lts.job.core.util.ListUtils;
 import com.lts.job.core.logger.Logger;
 import com.lts.job.core.logger.LoggerFactory;
+import com.lts.job.core.util.CollectionUtils;
+import com.lts.job.core.util.ListUtils;
 
 import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
diff --git a/job-core/src/main/java/com/lts/job/core/compiler/support/AbstractCompiler.java b/job-core/src/main/java/com/lts/job/core/compiler/support/AbstractCompiler.java
@@ -1,7 +1,7 @@
 package com.lts.job.core.compiler.support;
 
-import com.lts.job.core.util.ClassHelper;
 import com.lts.job.core.compiler.Compiler;
+import com.lts.job.core.util.ClassHelper;
 
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
diff --git a/job-core/src/main/java/com/lts/job/core/compiler/support/AdaptiveCompiler.java b/job-core/src/main/java/com/lts/job/core/compiler/support/AdaptiveCompiler.java
@@ -1,9 +1,9 @@
 package com.lts.job.core.compiler.support;
 
 
+import com.lts.job.core.compiler.Compiler;
 import com.lts.job.core.extension.Adaptive;
 import com.lts.job.core.extension.ExtensionLoader;
-import com.lts.job.core.compiler.Compiler;
 
 /**
  * AdaptiveCompiler. (SPI, Singleton, ThreadSafe)
diff --git a/job-core/src/main/java/com/lts/job/core/extension/ExtensionLoader.java b/job-core/src/main/java/com/lts/job/core/extension/ExtensionLoader.java
@@ -1,12 +1,12 @@
 package com.lts.job.core.extension;
 
 import com.lts.job.core.cluster.Config;
-import com.lts.job.core.util.ConcurrentHashSet;
-import com.lts.job.core.util.Holder;
-import com.lts.job.core.util.StringUtils;
 import com.lts.job.core.compiler.Compiler;
 import com.lts.job.core.logger.Logger;
 import com.lts.job.core.logger.LoggerFactory;
+import com.lts.job.core.util.ConcurrentHashSet;
+import com.lts.job.core.util.Holder;
+import com.lts.job.core.util.StringUtils;
 
 import java.io.BufferedReader;
 import java.io.InputStreamReader;
diff --git a/job-core/src/main/java/com/lts/job/core/factory/JobNodeConfigFactory.java b/job-core/src/main/java/com/lts/job/core/factory/JobNodeConfigFactory.java
@@ -1,7 +1,7 @@
 package com.lts.job.core.factory;
 
-import com.lts.job.core.constant.Constants;
 import com.lts.job.core.cluster.Config;
+import com.lts.job.core.constant.Constants;
 import com.lts.job.core.util.StringUtils;
 
 /**
diff --git a/job-core/src/main/java/com/lts/job/core/factory/NodeFactory.java b/job-core/src/main/java/com/lts/job/core/factory/NodeFactory.java
@@ -1,7 +1,7 @@
 package com.lts.job.core.factory;
 
-import com.lts.job.core.cluster.Node;
 import com.lts.job.core.cluster.Config;
+import com.lts.job.core.cluster.Node;
 import com.lts.job.core.util.NetUtils;
 
 /**
diff --git a/job-core/src/main/java/com/lts/job/core/listener/SelfChangeListener.java b/job-core/src/main/java/com/lts/job/core/listener/SelfChangeListener.java
@@ -6,7 +6,6 @@
 import com.lts.job.core.cluster.NodeType;
 import com.lts.job.core.constant.EcTopic;
 import com.lts.job.core.util.CollectionUtils;
-import com.lts.job.ec.EventCenter;
 import com.lts.job.ec.EventInfo;
 
 import java.util.List;
diff --git a/job-core/src/main/java/com/lts/job/core/registry/AbstractRegistry.java b/job-core/src/main/java/com/lts/job/core/registry/AbstractRegistry.java
@@ -1,12 +1,11 @@
 package com.lts.job.core.registry;
 
-import com.lts.job.core.Application;
 import com.lts.job.core.cluster.Config;
 import com.lts.job.core.cluster.Node;
-import com.lts.job.core.util.CollectionUtils;
-import com.lts.job.core.util.ConcurrentHashSet;
 import com.lts.job.core.logger.Logger;
 import com.lts.job.core.logger.LoggerFactory;
+import com.lts.job.core.util.CollectionUtils;
+import com.lts.job.core.util.ConcurrentHashSet;
 
 import java.util.*;
 import java.util.concurrent.ConcurrentHashMap;
diff --git a/job-core/src/main/java/com/lts/job/core/registry/redis/RedisRegistry.java b/job-core/src/main/java/com/lts/job/core/registry/redis/RedisRegistry.java
@@ -6,14 +6,14 @@
 import com.lts.job.core.constant.Constants;
 import com.lts.job.core.exception.NodeRegistryException;
 import com.lts.job.core.factory.NamedThreadFactory;
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.core.registry.FailbackRegistry;
 import com.lts.job.core.registry.NodeRegistryUtils;
 import com.lts.job.core.registry.NotifyEvent;
 import com.lts.job.core.registry.NotifyListener;
 import com.lts.job.core.util.CollectionUtils;
 import org.apache.commons.pool.impl.GenericObjectPool;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 import redis.clients.jedis.Jedis;
 import redis.clients.jedis.JedisPool;
 import redis.clients.jedis.JedisPubSub;
diff --git a/job-core/src/main/java/com/lts/job/core/remoting/HeartBeatMonitor.java b/job-core/src/main/java/com/lts/job/core/remoting/HeartBeatMonitor.java
@@ -3,14 +3,14 @@
 import com.lts.job.core.Application;
 import com.lts.job.core.cluster.Node;
 import com.lts.job.core.cluster.NodeType;
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.core.protocol.JobProtos;
 import com.lts.job.core.protocol.command.HeartBeatRequest;
 import com.lts.job.core.util.CollectionUtils;
 import com.lts.job.remoting.InvokeCallback;
 import com.lts.job.remoting.netty.ResponseFuture;
 import com.lts.job.remoting.protocol.RemotingCommand;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.util.List;
 import java.util.concurrent.CountDownLatch;
diff --git a/job-core/src/main/java/com/lts/job/core/remoting/RemotingClientDelegate.java b/job-core/src/main/java/com/lts/job/core/remoting/RemotingClientDelegate.java
@@ -5,13 +5,13 @@
 import com.lts.job.core.exception.JobTrackerNotFoundException;
 import com.lts.job.core.extension.ExtensionLoader;
 import com.lts.job.core.loadbalance.LoadBalance;
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.remoting.InvokeCallback;
 import com.lts.job.remoting.exception.RemotingCommandFieldCheckException;
 import com.lts.job.remoting.netty.NettyRemotingClient;
 import com.lts.job.remoting.netty.NettyRequestProcessor;
 import com.lts.job.remoting.protocol.RemotingCommand;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.util.List;
 import java.util.concurrent.CopyOnWriteArrayList;
diff --git a/job-core/src/main/java/com/lts/job/core/support/RetryScheduler.java b/job-core/src/main/java/com/lts/job/core/support/RetryScheduler.java
@@ -4,10 +4,10 @@
 import com.lts.job.core.domain.KVPair;
 import com.lts.job.core.file.FileAccessor;
 import com.lts.job.core.file.FileException;
-import com.lts.job.core.util.GenericsUtils;
-import com.lts.job.core.util.JSONUtils;
 import com.lts.job.core.logger.Logger;
 import com.lts.job.core.logger.LoggerFactory;
+import com.lts.job.core.util.GenericsUtils;
+import com.lts.job.core.util.JSONUtils;
 
 import java.io.IOException;
 import java.util.ArrayList;
diff --git a/job-core/src/main/java/com/lts/job/remoting/common/RemotingUtil.java b/job-core/src/main/java/com/lts/job/remoting/common/RemotingUtil.java
@@ -1,10 +1,10 @@
 package com.lts.job.remoting.common;
 
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelFutureListener;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.io.IOException;
 import java.lang.reflect.Method;
diff --git a/job-core/src/main/java/com/lts/job/remoting/netty/NettyDecoder.java b/job-core/src/main/java/com/lts/job/remoting/netty/NettyDecoder.java
@@ -1,13 +1,13 @@
 package com.lts.job.remoting.netty;
 
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.remoting.common.RemotingHelper;
 import com.lts.job.remoting.common.RemotingUtil;
 import com.lts.job.remoting.protocol.RemotingCommand;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 
 /**
diff --git a/job-core/src/main/java/com/lts/job/remoting/netty/NettyEncoder.java b/job-core/src/main/java/com/lts/job/remoting/netty/NettyEncoder.java
@@ -1,13 +1,13 @@
 package com.lts.job.remoting.netty;
 
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.remoting.common.RemotingHelper;
 import com.lts.job.remoting.common.RemotingUtil;
 import com.lts.job.remoting.protocol.RemotingCommand;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.MessageToByteEncoder;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.nio.ByteBuffer;
 
diff --git a/job-core/src/main/java/com/lts/job/remoting/netty/NettyRemotingAbstract.java b/job-core/src/main/java/com/lts/job/remoting/netty/NettyRemotingAbstract.java
@@ -1,5 +1,7 @@
 package com.lts.job.remoting.netty;
 
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.remoting.ChannelEventListener;
 import com.lts.job.remoting.InvokeCallback;
 import com.lts.job.remoting.common.Pair;
@@ -16,8 +18,6 @@
 import io.netty.channel.ChannelFutureListener;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.timeout.IdleState;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.util.HashMap;
 import java.util.Iterator;
diff --git a/job-core/src/main/java/com/lts/job/remoting/netty/NettyRemotingClient.java b/job-core/src/main/java/com/lts/job/remoting/netty/NettyRemotingClient.java
@@ -1,5 +1,7 @@
 package com.lts.job.remoting.netty;
 
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.remoting.ChannelEventListener;
 import com.lts.job.remoting.InvokeCallback;
 import com.lts.job.remoting.RemotingClient;
@@ -20,8 +22,6 @@
 import io.netty.handler.timeout.IdleStateEvent;
 import io.netty.handler.timeout.IdleStateHandler;
 import io.netty.util.concurrent.DefaultEventExecutorGroup;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.net.SocketAddress;
 import java.util.Timer;
diff --git a/job-core/src/main/java/com/lts/job/remoting/netty/NettyRemotingServer.java b/job-core/src/main/java/com/lts/job/remoting/netty/NettyRemotingServer.java
@@ -1,5 +1,7 @@
 package com.lts.job.remoting.netty;
 
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.remoting.ChannelEventListener;
 import com.lts.job.remoting.InvokeCallback;
 import com.lts.job.remoting.RemotingServer;
@@ -19,8 +21,6 @@
 import io.netty.handler.timeout.IdleStateEvent;
 import io.netty.handler.timeout.IdleStateHandler;
 import io.netty.util.concurrent.DefaultEventExecutorGroup;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.net.InetSocketAddress;
 import java.util.Timer;
diff --git a/job-core/src/main/java/com/lts/job/remoting/protocol/RemotingCommand.java b/job-core/src/main/java/com/lts/job/remoting/protocol/RemotingCommand.java
@@ -2,13 +2,13 @@
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.annotation.JSONField;
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.remoting.CommandBody;
 import com.lts.job.remoting.annotation.NotNull;
 import com.lts.job.remoting.exception.RemotingCommandException;
 import com.lts.job.remoting.exception.RemotingCommandFieldCheckException;
 import com.lts.job.remoting.util.ReflectionUtils;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.lang.annotation.Annotation;
 import java.lang.reflect.Field;
diff --git a/job-core/src/main/java/com/lts/job/store/mongo/MongoFactoryBean.java b/job-core/src/main/java/com/lts/job/store/mongo/MongoFactoryBean.java
@@ -1,11 +1,11 @@
 package com.lts.job.store.mongo;
 
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.mongodb.Mongo;
 import com.mongodb.MongoClient;
 import com.mongodb.MongoClientOptions;
 import com.mongodb.ServerAddress;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
diff --git a/job-core/src/main/java/com/lts/job/zookeeper/support/AbstractZookeeperClient.java b/job-core/src/main/java/com/lts/job/zookeeper/support/AbstractZookeeperClient.java
@@ -1,11 +1,11 @@
 package com.lts.job.zookeeper.support;
 
 
+import com.lts.job.core.logger.Logger;
+import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.zookeeper.ChildListener;
 import com.lts.job.zookeeper.StateListener;
 import com.lts.job.zookeeper.ZookeeperClient;
-import com.lts.job.core.logger.Logger;
-import com.lts.job.core.logger.LoggerFactory;
 
 import java.util.List;
 import java.util.Set;
diff --git a/job-core/src/test/java/com/lts/job/remoting/NettyRPCTest.java b/job-core/src/test/java/com/lts/job/remoting/NettyRPCTest.java
diff --git a/job-logger/job-logger-api/src/main/java/com/lts/job/biz/logger/JobLogger.java b/job-logger/job-logger-api/src/main/java/com/lts/job/biz/logger/JobLogger.java
diff --git a/job-queue/job-queue-api/src/main/java/com/lts/job/queue/JobFeedbackQueueFactory.java b/job-queue/job-queue-api/src/main/java/com/lts/job/queue/JobFeedbackQueueFactory.java
diff --git a/job-queue/job-queue-mongo/src/main/java/com/lts/job/queue/mongo/MongoJobFeedbackQueue.java b/job-queue/job-queue-mongo/src/main/java/com/lts/job/queue/mongo/MongoJobFeedbackQueue.java
diff --git a/job-queue/job-queue-mongo/src/main/java/com/lts/job/queue/mongo/MongoJobQueue.java b/job-queue/job-queue-mongo/src/main/java/com/lts/job/queue/mongo/MongoJobQueue.java
diff --git a/job-task-tracker/src/main/java/com/lts/job/task/tracker/TaskTracker.java b/job-task-tracker/src/main/java/com/lts/job/task/tracker/TaskTracker.java
diff --git a/job-task-tracker/src/main/java/com/lts/job/task/tracker/runner/JobRunnerDelegate.java b/job-task-tracker/src/main/java/com/lts/job/task/tracker/runner/JobRunnerDelegate.java
diff --git a/job-task-tracker/src/main/java/com/lts/job/task/tracker/runner/RunnerPool.java b/job-task-tracker/src/main/java/com/lts/job/task/tracker/runner/RunnerPool.java
diff --git a/job-tracker/src/main/java/com/lts/job/tracker/processor/JobPullProcessor.java b/job-tracker/src/main/java/com/lts/job/tracker/processor/JobPullProcessor.java
diff --git a/job-tracker/src/main/java/com/lts/job/tracker/support/ClientNotifier.java b/job-tracker/src/main/java/com/lts/job/tracker/support/ClientNotifier.java
diff --git a/job-tracker/src/main/java/com/lts/job/tracker/support/JobClientManager.java b/job-tracker/src/main/java/com/lts/job/tracker/support/JobClientManager.java
diff --git a/job-tracker/src/main/java/com/lts/job/tracker/support/JobReceiver.java b/job-tracker/src/main/java/com/lts/job/tracker/support/JobReceiver.java
diff --git a/job-tracker/src/main/java/com/lts/job/tracker/support/OldDataHandler.java b/job-tracker/src/main/java/com/lts/job/tracker/support/OldDataHandler.java
diff --git a/job-tracker/src/main/java/com/lts/job/tracker/support/policy/OldDataDeletePolicy.java b/job-tracker/src/main/java/com/lts/job/tracker/support/policy/OldDataDeletePolicy.java
