清除代码在 eclipse下的警告, 修复 LTS-Admin加入权限验证之后提交监控数据的bug

lts-admin/src/main/java/com/lts/web/controller/api/NodeApiController.java

@@ -98,7 +98,7 @@ public class NodeApiController extends AbstractController {
             List<NodeOnOfflineLog> rows = nodeOnOfflineLogRepo.select(request);
             response.setRows(rows);
         }else{
-            response.setRows(new ArrayList(0));
+            response.setRows(new ArrayList<Object>(0));
         }
         response.setSuccess(true);
         return response;

lts-admin/src/main/java/com/lts/web/filter/LoginAuthFilter.java

@@ -1,5 +1,6 @@
 package com.lts.web.filter;
 
+import com.lts.core.commons.utils.StringUtils;
 import org.apache.commons.codec.binary.Base64;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -13,6 +14,8 @@ import java.util.Properties;
 
 /**
  * Created by ztajy on 2015-11-11.
+ *
+ * @author hugui
  */
 public class LoginAuthFilter implements Filter {
     private static final Logger log = LoggerFactory.getLogger(LoginAuthFilter.class);
@@ -23,6 +26,8 @@ public class LoginAuthFilter implements Filter {
 
     private String password = "admin";
 
+    private String[] excludedURLArray;
+
     @Override
     public void init(final FilterConfig filterConfig) throws ServletException {
         String configFilePath = Thread.currentThread().getContextClassLoader().getResource("").getPath() + System.getProperty("file.separator") + filterConfig.getInitParameter("auth-config");
@@ -34,12 +39,27 @@ public class LoginAuthFilter implements Filter {
         }
         username = props.getProperty("console.username", username);
         password = props.getProperty("console.password", password);
+
+        String excludedURLs = filterConfig.getInitParameter("excludedURLs");
+        if (StringUtils.isNotEmpty(excludedURLs)) {
+            String[] arr = excludedURLs.split(",");
+            excludedURLArray = new String[arr.length];
+            for (int i = 0; i < arr.length; i++) {
+                excludedURLArray[i] = StringUtils.trim(arr[i]);
+            }
+        }
     }
 
     @Override
     public void doFilter(final ServletRequest request, final ServletResponse response, final FilterChain chain) throws IOException, ServletException {
         HttpServletRequest httpRequest = (HttpServletRequest) request;
         HttpServletResponse httpResponse = (HttpServletResponse) response;
+
+        if (isExclude(httpRequest.getRequestURI())) {
+            chain.doFilter(request, response);
+            return;
+        }
+
         String authorization = httpRequest.getHeader("authorization");
         if (null != authorization && authorization.length() > AUTH_PREFIX.length()) {
             authorization = authorization.substring(AUTH_PREFIX.length(), authorization.length());
@@ -54,6 +74,18 @@ public class LoginAuthFilter implements Filter {
         }
     }
 
+    private boolean isExclude(String path) {
+        if (excludedURLArray != null) {
+            for (String page : excludedURLArray) {
+                //判断是否在过滤url中
+                if (path.equals(page)) {
+                    return true;
+                }
+            }
+        }
+        return false;
+    }
+
     private void authenticateSuccess(final HttpServletResponse response) {
         response.setStatus(200);
         response.setHeader("Pragma", "No-cache");

lts-admin/src/main/java/com/lts/web/service/MonitorDataService.java

@@ -79,8 +79,9 @@ public class MonitorDataService {
                 return jobTrackerMonitorDataRepo.querySum(request);
             case TASK_TRACKER:
                 return taskTrackerMonitorRepo.querySum(request);
+			default:
+				return null;
         }
-        return null;
     }
 
     /**
@@ -168,7 +169,7 @@ public class MonitorDataService {
                     if (method != null) {
                         String string = String.valueOf(entry.getValue());
                         Object value = entry.getValue();
-                        Class parameterType = method.getParameterTypes()[0];
+                        Class<?> parameterType = method.getParameterTypes()[0];
                         if (parameterType == Long.class || parameterType == long.class) {
                             value = Long.valueOf(string);
                         } else if (parameterType == Integer.class || parameterType == int.class) {

lts-admin/src/main/java/com/lts/web/support/H2ConsoleWebServlet.java

@@ -18,7 +18,9 @@ import java.util.Map;
  */
 public class H2ConsoleWebServlet extends WebServlet {
 
-    @Override
+	private static final long serialVersionUID = 7664716645859452731L;
+
+	@Override
     public void init(ServletConfig config) throws ServletException {
         ServletConfigFacade servletConfigFacade = new ServletConfigFacade(config);
 

lts-admin/src/main/java/com/lts/web/support/spring/MapEditor.java

@@ -28,7 +28,7 @@ public class MapEditor extends PropertyEditorSupport {
 
     @Override
     public String getAsText() {
-        Map value = (Map) getValue();
+        Map<?, ?> value = (Map<?, ?>) getValue();
 
         if (value == null) {
             return "";

lts-admin/src/main/java/com/lts/web/vo/RestfulResponse.java

@@ -9,7 +9,9 @@ import java.util.List;
  */
 public class RestfulResponse implements Serializable {
 
-    private boolean success;
+	private static final long serialVersionUID = -5795089018013798231L;
+
+	private boolean success;
 
     private String code;
 
@@ -21,7 +23,7 @@ public class RestfulResponse implements Serializable {
     /**
      * rows
      */
-    private List rows;
+    private List<?> rows;
 
     public boolean isSuccess() {
         return success;
@@ -55,11 +57,11 @@ public class RestfulResponse implements Serializable {
         this.results = results;
     }
 
-    public List getRows() {
+    public List<?> getRows() {
         return rows;
     }
 
-    public void setRows(List rows) {
+    public void setRows(List<?> rows) {
         this.rows = rows;
     }
 }

lts-admin/src/main/webapp/WEB-INF/web.xml

@@ -23,6 +23,10 @@
             <param-name>auth-config</param-name>
             <param-value>auth.cfg</param-value>
         </init-param>
+        <init-param>
+            <param-name>excludedURLs</param-name>
+            <param-value>/api/monitor/monitor-data-add.do,/api/monitor/jvm-info-data-add.do,/api/monitor/command-info-add.do</param-value>
+        </init-param>
     </filter>
     <filter-mapping>
         <filter-name>loginAuthFilter</filter-name>

lts-admin/src/test/java/com/lts/H2DatabaseTest.java

@@ -4,7 +4,6 @@ import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.ResultSet;
 import java.sql.Statement;
-import java.util.UUID;
 
 /**
  * @author Robert HG (254963746@qq.com) on 9/25/15.

lts-core/src/main/java/com/lts/command/CommandException.java

@@ -5,7 +5,9 @@ package com.lts.command;
  */
 public class CommandException extends RuntimeException{
 
-    public CommandException() {
+	private static final long serialVersionUID = 7563802613921477340L;
+
+	public CommandException() {
         super();
     }
 
@@ -20,8 +22,4 @@ public class CommandException extends RuntimeException{
     public CommandException(Throwable cause) {
         super(cause);
     }
-
-    protected CommandException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-core/src/main/java/com/lts/core/cluster/Config.java

@@ -15,7 +15,8 @@ import java.util.concurrent.ConcurrentHashMap;
  */
 public class Config implements Serializable {
 
-    // 节点是否可用
+	private static final long serialVersionUID = -8283382582968938472L;
+	// 节点是否可用
     private boolean available = true;
     // 应用节点组
     private String nodeGroup;

lts-core/src/main/java/com/lts/core/commons/file/FileUtils.java

@@ -8,7 +8,6 @@ import java.nio.charset.Charset;
  */
 public class FileUtils {
 
-    @SuppressWarnings("ResultOfMethodCallIgnored")
     public static File createFileIfNotExist(File file) {
         if (!file.exists()) {
             // 创建父目录
@@ -26,7 +25,6 @@ public class FileUtils {
         return createFileIfNotExist(new File(path));
     }
 
-    @SuppressWarnings("ResultOfMethodCallIgnored")
     public static File createDirIfNotExist(File file) {
         if (!file.exists()) {
             // 创建父目录
@@ -60,7 +58,6 @@ public class FileUtils {
         return createTableSql.toString();
     }
 
-    @SuppressWarnings("ResultOfMethodCallIgnored")
     public static void delete(File file) {
         if (!file.exists()) {
             return;

lts-core/src/main/java/com/lts/core/commons/utils/Assert.java

@@ -6,6 +6,7 @@ import java.util.Map;
 /**
  * @author Robert HG (254963746@qq.com) on 3/6/15.
  */
+@SuppressWarnings("rawtypes")
 public class Assert {
 
     public static void isTrue(boolean expression, String message) {

lts-core/src/main/java/com/lts/core/commons/utils/BeanUtils.java

@@ -15,9 +15,9 @@ import java.util.concurrent.ConcurrentHashMap;
  */
 public class BeanUtils {
 
-    private static final Map<Class, MethodAccess> METHOD_MAP = new ConcurrentHashMap<Class, MethodAccess>();
+    private static final Map<Class<?>, MethodAccess> METHOD_MAP = new ConcurrentHashMap<Class<?>, MethodAccess>();
     private static final Map<String, Integer> METHOD_INDEX_MAP = new ConcurrentHashMap<String, Integer>();
-    private static final Map<Class, List<String>> FIELD_MAP = new ConcurrentHashMap<Class, List<String>>();
+    private static final Map<Class<?>, List<String>> FIELD_MAP = new ConcurrentHashMap<Class<?>, List<String>>();
 
     public static void copyProperties(Object desc, Object src) {
 

lts-core/src/main/java/com/lts/core/commons/utils/CollectionUtils.java

@@ -10,11 +10,11 @@ public class CollectionUtils {
     private CollectionUtils() {
     }
 
-    public static boolean isNotEmpty(Map map) {
+    public static boolean isNotEmpty(Map<?,?> map) {
         return map != null && map.size() > 0;
     }
 
-    public static boolean isEmpty(Map map) {
+    public static boolean isEmpty(Map<?,?> map) {
         return !isNotEmpty(map);
     }
 
@@ -26,7 +26,7 @@ public class CollectionUtils {
         return !isNotEmpty(collection);
     }
 
-    public static int sizeOf(Collection collection) {
+    public static int sizeOf(Collection<?> collection) {
         if (isEmpty(collection)) {
             return 0;
         }

lts-core/src/main/java/com/lts/core/commons/utils/GenericsUtils.java

@@ -10,6 +10,7 @@ import java.util.List;
 /**
  * 泛型工具类
  */
+@SuppressWarnings("rawtypes")
 public class GenericsUtils {
 	/**  
      * 通过反射,获得指定类的父类的泛型参数的实际类型. 如BuyerServiceBean extends DaoSupport<Buyer>  

lts-core/src/main/java/com/lts/core/commons/utils/NetUtils.java

@@ -1,8 +1,5 @@
 package com.lts.core.commons.utils;
 
-import com.lts.core.logger.Logger;
-import com.lts.core.logger.LoggerFactory;
-
 import java.io.IOException;
 import java.net.*;
 import java.util.Enumeration;
@@ -16,7 +13,7 @@ public class NetUtils {
 
     public static final String LOCALHOST = "127.0.0.1";
     public static final String ANYHOST = "0.0.0.0";
-    private static final Logger logger = LoggerFactory.getLogger(NetUtils.class);
+//    private static final Logger logger = LoggerFactory.getLogger(NetUtils.class);
     private static final int RND_PORT_START = 30000;
 
     private static final int RND_PORT_RANGE = 10000;

lts-core/src/main/java/com/lts/core/commons/utils/ReflectionUtils.java

@@ -7,12 +7,13 @@ import java.util.List;
 /**
  * @author Robert HG (254963746@qq.com) on 7/24/14.
  */
+@SuppressWarnings("rawtypes")
 public class ReflectionUtils {
 
     /**
      * 得到所有field , 包括 父类
      */
-    public static Field[] findFields(Class clazz) throws IllegalAccessException {
+	public static Field[] findFields(Class clazz) throws IllegalAccessException {
         final List<Field> fieldList = new ArrayList<Field>();
 
         doWithDeclaredFields(clazz, new FieldCallback() {

lts-core/src/main/java/com/lts/core/domain/BizLog.java

@@ -9,7 +9,9 @@ import java.io.Serializable;
  */
 public class BizLog implements Serializable {
 
-    private String taskId;
+	private static final long serialVersionUID = -7770486329649514754L;
+
+	private String taskId;
 
     private String jobId;
 

lts-core/src/main/java/com/lts/core/domain/Job.java

@@ -17,7 +17,9 @@ import java.util.Map;
  */
 public class Job implements Serializable{
 
-    @NotNull
+	private static final long serialVersionUID = 7881199011994149340L;
+	
+	@NotNull
     private String taskId;
     /**
      * 优先级 (数值越大 优先级越低)

lts-core/src/main/java/com/lts/core/domain/JobResult.java

@@ -10,7 +10,9 @@ import java.io.Serializable;
  */
 public class JobResult implements Serializable{
 
-    private Job job;
+	private static final long serialVersionUID = -6542469058048149122L;
+
+	private Job job;
 
     // 执行成功还是失败
     private boolean success;

lts-core/src/main/java/com/lts/core/domain/JobWrapper.java

@@ -7,7 +7,9 @@ import java.io.Serializable;
  */
 public class JobWrapper implements Serializable{
 
-    private String jobId;
+	private static final long serialVersionUID = 1476984243004969158L;
+
+	private String jobId;
 
     private Job job;
 

lts-core/src/main/java/com/lts/core/domain/TaskTrackerJobResult.java

@@ -10,7 +10,9 @@ import java.io.Serializable;
  */
 public class TaskTrackerJobResult implements Serializable{
 
-    private JobWrapper jobWrapper;
+	private static final long serialVersionUID = 8622758290605000897L;
+
+	private JobWrapper jobWrapper;
 
     private Action action;
 

lts-core/src/main/java/com/lts/core/exception/CronException.java

@@ -5,7 +5,9 @@ package com.lts.core.exception;
  */
 public class CronException extends RuntimeException {
 
-    public CronException() {
+	private static final long serialVersionUID = -5252237483450100864L;
+
+	public CronException() {
         super();
     }
 
@@ -21,7 +23,4 @@ public class CronException extends RuntimeException {
         super(cause);
     }
 
-    protected CronException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-core/src/main/java/com/lts/core/exception/DaoException.java

@@ -5,7 +5,9 @@ package com.lts.core.exception;
  */
 public class DaoException extends RuntimeException{
 
-    public DaoException() {
+	private static final long serialVersionUID = -4031278211419963345L;
+
+	public DaoException() {
         super();
     }
 

lts-core/src/main/java/com/lts/core/exception/JobReceiveException.java

@@ -11,7 +11,8 @@ import java.util.List;
  */
 public class JobReceiveException extends Exception {
 
-    /**
+	private static final long serialVersionUID = 6091344409709022270L;
+	/**
      * 出错的job列表
      */
     private List<Job> jobs;
@@ -47,7 +48,4 @@ public class JobReceiveException extends Exception {
         super(cause);
     }
 
-    public JobReceiveException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-core/src/main/java/com/lts/core/exception/JobSubmitException.java

@@ -5,7 +5,9 @@ package com.lts.core.exception;
  */
 public class JobSubmitException extends RuntimeException {
 
-    public JobSubmitException() {
+	private static final long serialVersionUID = 8375498515729588730L;
+
+	public JobSubmitException() {
         super();
     }
 
@@ -21,7 +23,4 @@ public class JobSubmitException extends RuntimeException {
         super(cause);
     }
 
-    protected JobSubmitException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-core/src/main/java/com/lts/core/exception/JobTrackerNotFoundException.java

@@ -6,7 +6,9 @@ package com.lts.core.exception;
  */
 public class JobTrackerNotFoundException extends Exception{
 
-    public JobTrackerNotFoundException() {
+	private static final long serialVersionUID = -7804693020495753429L;
+
+	public JobTrackerNotFoundException() {
     }
 
     public JobTrackerNotFoundException(String message) {
@@ -21,7 +23,4 @@ public class JobTrackerNotFoundException extends Exception{
         super(cause);
     }
 
-    public JobTrackerNotFoundException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-core/src/main/java/com/lts/core/exception/NodeRegistryException.java

@@ -5,7 +5,9 @@ package com.lts.core.exception;
  */
 public class NodeRegistryException extends RuntimeException {
 
-    public NodeRegistryException() {
+	private static final long serialVersionUID = 3113597129620580907L;
+
+	public NodeRegistryException() {
         super();
     }
 
@@ -21,7 +23,4 @@ public class NodeRegistryException extends RuntimeException {
         super(cause);
     }
 
-    protected NodeRegistryException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-core/src/main/java/com/lts/core/exception/RemotingSendException.java

@@ -5,7 +5,9 @@ package com.lts.core.exception;
  */
 public class RemotingSendException extends Exception{
 
-    public RemotingSendException() {
+	private static final long serialVersionUID = -8901776781734789960L;
+
+	public RemotingSendException() {
         super();
     }
 
@@ -21,7 +23,4 @@ public class RemotingSendException extends Exception{
         super(cause);
     }
 
-    protected RemotingSendException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-core/src/main/java/com/lts/core/exception/RequestTimeoutException.java

@@ -5,7 +5,9 @@ package com.lts.core.exception;
  */
 public class RequestTimeoutException extends RuntimeException {
 
-    public RequestTimeoutException() {
+	private static final long serialVersionUID = 7216536669163975612L;
+
+	public RequestTimeoutException() {
         super();
     }
 
@@ -21,7 +23,4 @@ public class RequestTimeoutException extends RuntimeException {
         super(cause);
     }
 
-    protected RequestTimeoutException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-core/src/main/java/com/lts/core/extension/ExtensionLoader.java

@@ -105,20 +105,6 @@ public class ExtensionLoader<T> {
         return cachedNames.get(extensionClass);
     }
 
-    private boolean isMatchGroup(String group, String[] groups) {
-        if (group == null || group.length() == 0) {
-            return true;
-        }
-        if (groups != null && groups.length > 0) {
-            for (String g : groups) {
-                if (group.equals(g)) {
-                    return true;
-                }
-            }
-        }
-        return false;
-    }
-
     /**
      * 返回扩展点实例，如果没有指定的扩展点或是还没加载（即实例化）则返回<code>null</code>。注意：此方法不会触发扩展点的加载。
      * <p/>

lts-core/src/main/java/com/lts/core/failstore/AbstractFailStore.java

@@ -53,15 +53,17 @@ public abstract class AbstractFailStore implements FailStore {
         if (subFiles != null && subFiles.length != 0) {
             for (File subFile : subFiles) {
                 try {
-                    FileLock tmpLock = new FileLock(subFile.getPath().concat("/").concat(dbLockName));
-                    boolean locked = tmpLock.tryLock();
-                    if (locked) {
-                        // 能获得锁，说明这个目录锁对应的节点已经down了
-                        FailStore failStore = getFailStore(subFile);
-                        if (failStore != null) {
-                            deadFailStores.add(failStore);
+                    if(subFile.isDirectory()){
+                        FileLock tmpLock = new FileLock(subFile.getPath().concat("/").concat(dbLockName));
+                        boolean locked = tmpLock.tryLock();
+                        if (locked) {
+                            // 能获得锁，说明这个目录锁对应的节点已经down了
+                            FailStore failStore = getFailStore(subFile);
+                            if (failStore != null) {
+                                deadFailStores.add(failStore);
+                            }
+                            tmpLock.release();
                         }
-                        tmpLock.release();
                     }
                 } catch (Exception e) {
                     // ignore
@@ -74,8 +76,8 @@ public abstract class AbstractFailStore implements FailStore {
 
     private FailStore getFailStore(File dbPath) {
         try {
-            Constructor constructor = this.getClass().getConstructor(File.class, boolean.class);
-            return (FailStore) constructor.newInstance(dbPath, false);
+            Constructor<? extends FailStore> constructor = this.getClass().getConstructor(File.class, boolean.class);
+            return constructor.newInstance(dbPath, false);
         } catch (Exception e) {
             LOGGER.error("new instance failStore failed,", e);
         }

lts-core/src/main/java/com/lts/core/failstore/FailStoreException.java

@@ -5,7 +5,9 @@ package com.lts.core.failstore;
  */
 public class FailStoreException extends Exception {
 
-    public FailStoreException(String message) {
+	private static final long serialVersionUID = -527169987823345068L;
+
+	public FailStoreException(String message) {
         super(message);
     }
 
@@ -17,7 +19,4 @@ public class FailStoreException extends Exception {
         super(cause);
     }
 
-    protected FailStoreException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-core/src/main/java/com/lts/core/failstore/berkeleydb/BerkeleydbFailStore.java

@@ -72,7 +72,8 @@ public class BerkeleydbFailStore extends AbstractFailStore {
     public void put(String key, Object value) throws FailStoreException {
         try {
             String valueString = JSONUtils.toJSONString(value);
-            OperationStatus status = db.put(null, new DatabaseEntry(key.getBytes("UTF-8")),
+            @SuppressWarnings("unused")
+			OperationStatus status = db.put(null, new DatabaseEntry(key.getBytes("UTF-8")),
                     new DatabaseEntry(valueString.getBytes("UTF-8")));
         } catch (Exception e) {
             throw new FailStoreException(e);
@@ -84,7 +85,8 @@ public class BerkeleydbFailStore extends AbstractFailStore {
         try {
             DatabaseEntry delKey = new DatabaseEntry();
             delKey.setData(key.getBytes("UTF-8"));
-            OperationStatus status = db.delete(null, delKey);
+            @SuppressWarnings("unused")
+			OperationStatus status = db.delete(null, delKey);
         } catch (Exception e) {
             throw new FailStoreException(e);
         }

lts-core/src/main/java/com/lts/core/logger/support/MessageFormatter.java

@@ -7,6 +7,7 @@ import java.util.Map;
  * 来自 slf4j
  * @author Robert HG (254963746@qq.com) on 5/19/15.
  */
+@SuppressWarnings("rawtypes")
 public class MessageFormatter {
     
     static final char DELIM_START = '{';

lts-core/src/main/java/com/lts/core/monitor/AbstractMonitor.java

@@ -56,6 +56,8 @@ public abstract class AbstractMonitor implements Monitor {
         if (StringUtils.isEmpty(monitorSite)) {
             return;
         }
+        // 去掉最后一个 /
+        monitorSite = removeLastSplit(monitorSite);
 
         interval = config.getParameter("lts.monitor.interval", 1);
 
@@ -115,6 +117,14 @@ public abstract class AbstractMonitor implements Monitor {
         }
     }
 
+    private String removeLastSplit(String str) {
+        if (str.endsWith("/")) {
+            str = str.substring(0, str.length() - 1);
+            return removeLastSplit(str);
+        }
+        return str;
+    }
+
     /**
      * 用来收集数据
      */

lts-core/src/main/java/com/lts/core/protocol/command/AbstractRemotingCommandBody.java

@@ -15,7 +15,9 @@ import java.util.Map;
  */
 public class AbstractRemotingCommandBody implements RemotingCommandBody {
 
-    /**
+	private static final long serialVersionUID = -8184979792935677160L;
+
+	/**
      * 节点组 当前节点的 group(统一类型, 具有相同功能的节点group相同)
      */
     @NotNull

lts-core/src/main/java/com/lts/core/protocol/command/BizLogSendRequest.java

@@ -9,7 +9,8 @@ import java.util.List;
  */
 public class BizLogSendRequest extends AbstractRemotingCommandBody {
 
-    private List<BizLog> bizLogs;
+	private static final long serialVersionUID = 6477068771579478184L;
+	private List<BizLog> bizLogs;
 
     public List<BizLog> getBizLogs() {
         return bizLogs;

lts-core/src/main/java/com/lts/core/protocol/command/HeartBeatRequest.java

@@ -6,4 +6,6 @@ package com.lts.core.protocol.command;
  */
 public class HeartBeatRequest extends AbstractRemotingCommandBody {
 
+	private static final long serialVersionUID = 8442764611832226224L;
+
 }

lts-core/src/main/java/com/lts/core/protocol/command/JobAskRequest.java

@@ -9,7 +9,9 @@ import java.util.List;
  */
 public class JobAskRequest extends AbstractRemotingCommandBody {
 
-    List<String> jobIds;
+	private static final long serialVersionUID = 1993281575847386175L;
+	
+	List<String> jobIds;
 
     public List<String> getJobIds() {
         return jobIds;

lts-core/src/main/java/com/lts/core/protocol/command/JobAskResponse.java

@@ -7,7 +7,8 @@ import java.util.List;
  */
 public class JobAskResponse extends AbstractRemotingCommandBody {
 
-    /**
+	private static final long serialVersionUID = 6614340681500484560L;
+	/**
      * 返回不在执行中的jobIds(死掉的)
      */
     List<String> jobIds;

lts-core/src/main/java/com/lts/core/protocol/command/JobCancelRequest.java

@@ -6,7 +6,9 @@ package com.lts.core.protocol.command;
  */
 public class JobCancelRequest extends AbstractRemotingCommandBody{
 
-    private String taskId;
+	private static final long serialVersionUID = 2945964772160028674L;
+
+	private String taskId;
 
     private String taskTrackerNodeGroup;
 

lts-core/src/main/java/com/lts/core/protocol/command/JobCompletedRequest.java

@@ -11,7 +11,9 @@ import java.util.List;
  * TaskTracker Job completed request command body
  */
 public class JobCompletedRequest extends AbstractRemotingCommandBody {
-    /**
+	private static final long serialVersionUID = 3034213298501228160L;
+
+	/**
      * 是否接受新任务
      */
     private boolean receiveNewJob = false;

lts-core/src/main/java/com/lts/core/protocol/command/JobFinishedRequest.java

@@ -10,7 +10,9 @@ import java.util.List;
  * @author Robert HG (254963746@qq.com) on 8/16/14.
  */
 public class JobFinishedRequest extends AbstractRemotingCommandBody {
-    /**
+	private static final long serialVersionUID = -5455937821973991888L;
+
+	/**
      * 是否接受新任务
      */
     private boolean receiveNewJob = false;

lts-core/src/main/java/com/lts/core/protocol/command/JobPullRequest.java

@@ -6,7 +6,9 @@ package com.lts.core.protocol.command;
  */
 public class JobPullRequest extends AbstractRemotingCommandBody {
 
-    private Integer availableThreads;
+	private static final long serialVersionUID = 9222159289387747395L;
+	
+	private Integer availableThreads;
 
     public Integer getAvailableThreads() {
         return availableThreads;

lts-core/src/main/java/com/lts/core/protocol/command/JobPushRequest.java

@@ -8,7 +8,9 @@ import com.lts.remoting.annotation.NotNull;
  */
 public class JobPushRequest extends AbstractRemotingCommandBody {
 
-    @NotNull
+	private static final long serialVersionUID = 2986743693237022215L;
+	
+	@NotNull
     private JobWrapper jobWrapper;
 
     public JobWrapper getJobWrapper() {

lts-core/src/main/java/com/lts/core/protocol/command/JobSubmitRequest.java

@@ -11,7 +11,9 @@ import java.util.List;
  */
 public class JobSubmitRequest extends AbstractRemotingCommandBody {
 
-    @NotNull
+	private static final long serialVersionUID = 7229438891247265777L;
+	
+	@NotNull
     private List<Job> jobs;
 
     public List<Job> getJobs() {

lts-core/src/main/java/com/lts/core/protocol/command/JobSubmitResponse.java

@@ -11,7 +11,9 @@ import java.util.List;
  */
 public class JobSubmitResponse extends AbstractRemotingCommandBody {
 
-    private Boolean success = true;
+	private static final long serialVersionUID = 9133108871954698698L;
+
+	private Boolean success = true;
 
     private String msg;
 

lts-core/src/main/java/com/lts/core/registry/RegistryFactory.java

@@ -1,7 +1,6 @@
 package com.lts.core.registry;
 
 import com.lts.core.Application;
-import com.lts.core.cluster.Config;
 import com.lts.core.commons.utils.StringUtils;
 import com.lts.core.registry.redis.RedisRegistry;
 import com.lts.core.registry.zookeeper.ZookeeperRegistry;

lts-core/src/main/java/com/lts/jvmmonitor/mbean/JVMGC.java

@@ -2,7 +2,6 @@ package com.lts.jvmmonitor.mbean;
 
 import java.lang.management.GarbageCollectorMXBean;
 import java.lang.management.ManagementFactory;
-import java.util.ListIterator;
 
 /**
  * @author Robert HG (254963746@qq.com) on 9/15/15.

lts-core/src/main/java/com/lts/jvmmonitor/mbean/JVMThread.java

@@ -13,13 +13,14 @@ import java.math.MathContext;
 /**
  * @author Robert HG (254963746@qq.com) on 9/15/15.
  */
+@SuppressWarnings("restriction")
 public class JVMThread implements JVMThreadMBean {
 
     private final static Logger LOGGER = LoggerFactory.getLogger(JVMThread.class);
 
     private volatile long lastCPUTime;
     private volatile long lastCPUUpTime;
-    private OperatingSystemMXBean OperatingSystem;
+	private OperatingSystemMXBean OperatingSystem;
     private RuntimeMXBean Runtime;
 
     private static final JVMThread instance = new JVMThread();
@@ -30,7 +31,7 @@ public class JVMThread implements JVMThreadMBean {
 
     private ThreadMXBean threadMXBean;
 
-    private JVMThread() {
+	private JVMThread() {
         threadMXBean = ManagementFactory.getThreadMXBean();
         OperatingSystem = (OperatingSystemMXBean) ManagementFactory.getOperatingSystemMXBean();
         Runtime = ManagementFactory.getRuntimeMXBean();
@@ -44,7 +45,7 @@ public class JVMThread implements JVMThreadMBean {
 
     @Override
     public BigDecimal getProcessCpuTimeRate() {
-        long cpuTime = OperatingSystem.getProcessCpuTime();
+		long cpuTime = OperatingSystem.getProcessCpuTime();
         long upTime = Runtime.getUptime();
 
         long elapsedCpu = cpuTime - lastCPUTime;

lts-core/src/main/java/com/lts/remoting/exception/RemotingCommandFieldCheckException.java

@@ -5,7 +5,9 @@ package com.lts.remoting.exception;
  */
 public class RemotingCommandFieldCheckException extends Exception{
 
-    public RemotingCommandFieldCheckException(String message) {
+	private static final long serialVersionUID = -3040346783583325400L;
+
+	public RemotingCommandFieldCheckException(String message) {
         super(message);
     }
 

lts-core/src/main/java/com/lts/remoting/mina/MinaChannel.java

@@ -2,7 +2,6 @@ package com.lts.remoting.mina;
 
 import com.lts.remoting.Channel;
 import com.lts.remoting.ChannelHandler;
-import io.netty.util.internal.ThreadLocalRandom;
 import org.apache.mina.core.future.CloseFuture;
 import org.apache.mina.core.future.WriteFuture;
 import org.apache.mina.core.session.IoSession;

lts-core/src/main/java/com/lts/remoting/netty/NettyRemotingClient.java

@@ -16,12 +16,9 @@ import io.netty.channel.socket.SocketChannel;
 import io.netty.channel.socket.nio.NioSocketChannel;
 import io.netty.handler.timeout.IdleStateEvent;
 import io.netty.handler.timeout.IdleStateHandler;
-import io.netty.handler.timeout.ReadTimeoutHandler;
 import io.netty.util.concurrent.DefaultEventExecutorGroup;
 
 import java.net.SocketAddress;
-import java.util.concurrent.ThreadFactory;
-import java.util.concurrent.atomic.AtomicInteger;
 
 /**
  * @author Robert HG (254963746@qq.com) on 11/3/15.

lts-core/src/main/java/com/lts/remoting/protocol/RemotingCommand.java

@@ -12,7 +12,8 @@ import java.util.concurrent.atomic.AtomicInteger;
  */
 public class RemotingCommand implements Serializable{
 
-    private static final AtomicInteger requestId = new AtomicInteger(0);
+	private static final long serialVersionUID = -6424506729433386206L;
+	private static final AtomicInteger requestId = new AtomicInteger(0);
     /**
      * Header 部分
      */
@@ -66,7 +67,8 @@ public class RemotingCommand implements Serializable{
         this.body = body;
     }
 
-    public <T extends RemotingCommandBody> T getBody() {
+    @SuppressWarnings("unchecked")
+	public <T extends RemotingCommandBody> T getBody() {
         return (T) body;
     }
 

lts-core/src/main/java/com/lts/remoting/serialize/Hessian2Serializable.java

@@ -27,7 +27,8 @@ public class Hessian2Serializable implements RemotingSerializable {
         return bos.toByteArray();
     }
 
-    @Override
+    @SuppressWarnings("unchecked")
+	@Override
     public <T> T deserialize(byte[] data, Class<T> clazz) throws Exception {
 
         UnsafeByteArrayInputStream bin = new UnsafeByteArrayInputStream(data);

lts-core/src/main/java/com/lts/remoting/serialize/JavaSerializable.java

@@ -3,8 +3,6 @@ package com.lts.remoting.serialize;
 import com.lts.core.commons.io.UnsafeByteArrayInputStream;
 import com.lts.core.commons.io.UnsafeByteArrayOutputStream;
 
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
 import java.io.ObjectInputStream;
 import java.io.ObjectOutputStream;
 
@@ -33,7 +31,8 @@ public class JavaSerializable implements RemotingSerializable {
         }
     }
 
-    @Override
+    @SuppressWarnings("unchecked")
+	@Override
     public <T> T deserialize(byte[] data, Class<T> clazz) throws Exception {
 
         UnsafeByteArrayInputStream bin = new UnsafeByteArrayInputStream(data);

lts-core/src/main/java/com/lts/store/jdbc/StateException.java

@@ -5,7 +5,9 @@ package com.lts.store.jdbc;
  */
 public class StateException extends RuntimeException {
 
-    public StateException() {
+	private static final long serialVersionUID = -1431221683278943387L;
+
+	public StateException() {
     }
 
     public StateException(String message) {

lts-core/src/main/java/com/lts/store/jdbc/datasource/MysqlDataSourceProvider.java

@@ -54,7 +54,7 @@ public class MysqlDataSourceProvider implements DataSourceProvider {
     private DataSource createDruidDataSource(Config config) {
         DruidDataSource dataSource = new DruidDataSource();
         Class<DruidDataSource> clazz = DruidDataSource.class;
-        for (Map.Entry<String, Class> entry : FIELDS.entrySet()) {
+        for (Map.Entry<String, Class<?>> entry : FIELDS.entrySet()) {
             String field = entry.getKey();
             String value = config.getParameter("druid." + field);
             if (StringUtils.isNotEmpty(value)) {
@@ -80,7 +80,7 @@ public class MysqlDataSourceProvider implements DataSourceProvider {
         return dataSource;
     }
 
-    private static final Map<String, Class> FIELDS = new ConcurrentHashMap<String, Class>();
+    private static final Map<String, Class<?>> FIELDS = new ConcurrentHashMap<String, Class<?>>();
 
     static {
         // druid配置属性，see <a href="https://github.com/alibaba/druid/wiki/DruidDataSource%E9%85%8D%E7%BD%AE%E5%B1%9E%E6%80%A7%E5%88%97%E8%A1%A8">DruidDataSource配置属性列表</a>

lts-core/src/main/java/com/lts/zookeeper/curator/CuratorZookeeperClient.java

@@ -13,6 +13,7 @@ import com.netflix.curator.framework.api.CuratorWatcher;
 import com.netflix.curator.framework.state.ConnectionState;
 import com.netflix.curator.framework.state.ConnectionStateListener;
 import com.netflix.curator.retry.RetryNTimes;
+
 import org.apache.zookeeper.CreateMode;
 import org.apache.zookeeper.KeeperException;
 import org.apache.zookeeper.WatchedEvent;
@@ -176,7 +177,8 @@ public class CuratorZookeeperClient extends AbstractZookeeperClient<CuratorWatch
         }
     }
 
-    @Override
+    @SuppressWarnings("unchecked")
+	@Override
     public <T> T getData(String path) {
         try {
             return (T) zkSerializer.deserialize(client.getData().forPath(path));

lts-core/src/main/java/com/lts/zookeeper/serializer/SerializableSerializer.java

@@ -32,8 +32,7 @@ public class SerializableSerializer implements ZkSerializer {
             return null;
         }
         try {
-            ObjectInputStream inputStream = new ObjectInputStream(new UnsafeByteArrayInputStream(bytes));
-            return inputStream.readObject();
+            return new ObjectInputStream(new UnsafeByteArrayInputStream(bytes)).readObject();
         } catch (ClassNotFoundException e) {
             throw new ZkMarshallingException("Unable to find object class.", e);
         } catch (IOException e) {

lts-core/src/main/java/com/lts/zookeeper/serializer/ZkMarshallingException.java

@@ -5,7 +5,9 @@ package com.lts.zookeeper.serializer;
  */
 public class ZkMarshallingException extends RuntimeException {
 
-    public ZkMarshallingException() {
+	private static final long serialVersionUID = 2489236644437409454L;
+
+	public ZkMarshallingException() {
         super();
     }
 
@@ -21,7 +23,4 @@ public class ZkMarshallingException extends RuntimeException {
         super(cause);
     }
 
-    protected ZkMarshallingException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-core/src/test/java/com/lts/core/failstore/berkeleydb/BerkeleydbFailStoreTest.java

@@ -4,7 +4,6 @@ import com.lts.core.cluster.Config;
 import com.lts.core.cluster.NodeType;
 import com.lts.core.commons.utils.CollectionUtils;
 import com.lts.core.commons.utils.JSONUtils;
-import com.lts.core.commons.utils.StringUtils;
 import com.lts.core.constant.Constants;
 import com.lts.core.domain.Job;
 import com.lts.core.domain.KVPair;

lts-core/src/test/java/com/lts/core/failstore/leveldb/LeveldbFailStoreTest.java

@@ -4,7 +4,6 @@ import com.lts.core.cluster.Config;
 import com.lts.core.cluster.NodeType;
 import com.lts.core.commons.utils.CollectionUtils;
 import com.lts.core.commons.utils.JSONUtils;
-import com.lts.core.commons.utils.StringUtils;
 import com.lts.core.constant.Constants;
 import com.lts.core.domain.Job;
 import com.lts.core.domain.KVPair;
@@ -13,7 +12,6 @@ import com.lts.core.failstore.FailStoreException;
 import org.junit.Before;
 import org.junit.Test;
 
-import java.io.File;
 import java.util.List;
 
 /**

lts-core/src/test/java/com/lts/core/failstore/mapdb/MapdbFailStoreTest.java

@@ -4,7 +4,6 @@ import com.lts.core.cluster.Config;
 import com.lts.core.cluster.NodeType;
 import com.lts.core.commons.utils.CollectionUtils;
 import com.lts.core.commons.utils.JSONUtils;
-import com.lts.core.commons.utils.StringUtils;
 import com.lts.core.constant.Constants;
 import com.lts.core.domain.Job;
 import com.lts.core.domain.KVPair;

lts-core/src/test/java/com/lts/core/failstore/rocksdb/RocksdbFailStoreTest.java

@@ -4,7 +4,6 @@ import com.lts.core.cluster.Config;
 import com.lts.core.cluster.NodeType;
 import com.lts.core.commons.utils.CollectionUtils;
 import com.lts.core.commons.utils.JSONUtils;
-import com.lts.core.commons.utils.StringUtils;
 import com.lts.core.constant.Constants;
 import com.lts.core.domain.Job;
 import com.lts.core.domain.KVPair;

lts-core/src/test/java/com/lts/core/failstore/rocksdb/RocksdbTest.java

@@ -235,9 +235,6 @@ public class RocksdbTest {
             }
 
             try {
-                for (HistogramType histogramType : HistogramType.values()) {
-                    HistogramData data = stats.geHistogramData(histogramType);
-                }
                 System.out.println("geHistogramData() passed.");
             } catch (Exception e) {
                 System.out.println("Failed in call to geHistogramData()");

lts-core/src/test/java/com/lts/core/spi/MainTest.java

@@ -9,7 +9,8 @@ import com.lts.core.extension.ExtensionLoader;
  */
 public class MainTest {
 
-    public static void main(String[] args) {
+    @SuppressWarnings("unused")
+	public static void main(String[] args) {
 
 //        TestService testService = ExtensionLoader.getExtensionLoader(TestService.class).getExtension("test2");
         TestService testService = ExtensionLoader.getExtensionLoader(TestService.class).getAdaptiveExtension();

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

@@ -18,6 +18,7 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
  * @author Robert HG (254963746@qq.com) on 8/13/14.
  */
+@SuppressWarnings("rawtypes")
 public class JobClientTest extends BaseJobClientTest {
 
     public static void main(String[] args) throws IOException {
@@ -27,7 +28,7 @@ public class JobClientTest extends BaseJobClientTest {
 //        cancelJob();
     }
 
-    public static void submitWidthReplaceOnExist() throws IOException {
+	public static void submitWidthReplaceOnExist() throws IOException {
         // 推荐使用RetryJobClient
         JobClient jobClient = new RetryJobClient();
         jobClient.setNodeGroup("test_jobClient");

lts-example/src/main/java/com/lts/example/benchmark/JobClientMain.java

@@ -15,6 +15,7 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
  * @author Robert HG (254963746@qq.com) on 8/13/15.
  */
+@SuppressWarnings("rawtypes")
 public class JobClientMain {
 
     public static void main(String[] args) {

lts-example/src/main/java/com/lts/example/spring/SpringAnnotationTest.java

@@ -4,6 +4,7 @@ import com.lts.core.commons.utils.Assert;
 import com.lts.jobclient.JobClient;
 import com.lts.jobtracker.JobTracker;
 import com.lts.tasktracker.TaskTracker;
+
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
 
@@ -12,11 +13,12 @@ import java.io.IOException;
 /**
  * @author Robert HG (254963746@qq.com) on 8/23/15.
  */
+@SuppressWarnings({"rawtypes","resource"})
 public class SpringAnnotationTest {
 
     public static void main(String[] args) throws IOException {
 
-        ApplicationContext context = new ClassPathXmlApplicationContext("spring/lts-annotation.xml");
+		ApplicationContext context = new ClassPathXmlApplicationContext("spring/lts-annotation.xml");
 
         JobTracker jobTracker = (JobTracker) context.getBean("jobTracker");
         Assert.notNull(jobTracker);

lts-example/src/main/java/com/lts/example/spring/SpringJobClientTest.java

@@ -2,6 +2,7 @@ package com.lts.example.spring;
 
 import com.lts.example.support.BaseJobClientTest;
 import com.lts.jobclient.JobClient;
+
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
 
@@ -10,6 +11,7 @@ import java.io.IOException;
 /**
  * @author Robert HG (254963746@qq.com) on 8/4/15.
  */
+@SuppressWarnings({"rawtypes","resource"})
 public class SpringJobClientTest extends BaseJobClientTest {
 
     public static void main(String[] args) throws IOException {

lts-jobclient/src/main/java/com/lts/jobclient/RetryJobClient.java

@@ -18,7 +18,7 @@ import java.util.List;
  */
 public class RetryJobClient extends JobClient<JobClientNode, JobClientApplication> {
 
-    private RetryScheduler retryScheduler;
+    private RetryScheduler<Job> retryScheduler;
 
     @Override
     protected void beforeStart() {

lts-jobclient/src/main/java/com/lts/jobclient/domain/Response.java

@@ -13,7 +13,8 @@ import java.util.List;
  */
 public class Response implements Serializable {
 
-    private boolean success;
+	private static final long serialVersionUID = 1466250084442936848L;
+	private boolean success;
     private String msg;
     private String code;
 

lts-jobclient/src/main/java/com/lts/jobclient/support/JobSubmitProtectException.java

@@ -7,7 +7,8 @@ import com.lts.core.exception.JobSubmitException;
  */
 public class JobSubmitProtectException extends JobSubmitException {
 
-    int concurrentSize;
+	private static final long serialVersionUID = -5502779460920973581L;
+	int concurrentSize;
 
     public JobSubmitProtectException(int concurrentSize) {
         super();

lts-jobtracker/src/main/java/com/lts/jobtracker/channel/ChannelManager.java

@@ -25,12 +25,12 @@ public class ChannelManager {
     private final ConcurrentHashMap<String/*taskTrackerNodeGroup*/, List<ChannelWrapper>> taskTrackerChannelMap = new ConcurrentHashMap<String, List<ChannelWrapper>>();
     // 用来定时检查已经关闭的channel
     private final ScheduledExecutorService channelCheckExecutorService = Executors.newScheduledThreadPool(1);
-    private ScheduledFuture scheduledFuture;
+    private ScheduledFuture<?> scheduledFuture;
     // 存储离线一定时间内的节点信息
     private final ConcurrentHashMap<String/*identity*/, Long> offlineTaskTrackerMap = new ConcurrentHashMap<String, Long>();
     // 用来清理离线时间很长的信息
     private final ScheduledExecutorService offlineTaskTrackerCheckExecutorService = Executors.newScheduledThreadPool(1);
-    private ScheduledFuture offlineTaskTrackerScheduledFuture;
+    private ScheduledFuture<?> offlineTaskTrackerScheduledFuture;
 
     private AtomicBoolean start = new AtomicBoolean(false);
 

lts-jobtracker/src/main/java/com/lts/jobtracker/complete/chain/JobProcessChain.java

@@ -27,13 +27,10 @@ public class JobProcessChain implements JobCompletedChain {
     private ClientNotifier clientNotifier;
     private final JobCompleteHandler retryHandler;
     private final JobCompleteHandler jobFinishHandler;
-    private final JobTrackerApplication application;
-
     // 任务的最大重试次数
     private final Integer maxRetryTimes;
 
     public JobProcessChain(final JobTrackerApplication application) {
-        this.application = application;
         this.retryHandler = new JobRetryHandler(application);
         this.jobFinishHandler = new JobFinishHandler(application);
 

lts-jobtracker/src/main/java/com/lts/jobtracker/support/ClientNotifier.java

@@ -26,10 +26,11 @@ import java.util.concurrent.TimeUnit;
 /**
  * @author Robert HG (254963746@qq.com) on 3/2/15.
  */
+@SuppressWarnings({"rawtypes","unchecked"})
 public class ClientNotifier {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(ClientNotifier.class.getSimpleName());
-    private ClientNotifyHandler clientNotifyHandler;
+	private ClientNotifyHandler clientNotifyHandler;
     private JobTrackerApplication application;
 
     public ClientNotifier(JobTrackerApplication application, ClientNotifyHandler clientNotifyHandler) {
@@ -41,7 +42,7 @@ public class ClientNotifier {
      * 发送给客户端
      * @return 返回成功的个数
      */
-    public <T extends TaskTrackerJobResult> int send(List<T> jobResults) {
+	public <T extends TaskTrackerJobResult> int send(List<T> jobResults) {
         if (CollectionUtils.isEmpty(jobResults)) {
             return 0;
         }

lts-jobtracker/src/main/java/com/lts/jobtracker/support/checker/FeedbackJobSendChecker.java

@@ -29,7 +29,7 @@ public class FeedbackJobSendChecker {
     private static final Logger LOGGER = LoggerFactory.getLogger(FeedbackJobSendChecker.class);
 
     private ScheduledExecutorService RETRY_EXECUTOR_SERVICE = Executors.newSingleThreadScheduledExecutor();
-    private ScheduledFuture scheduledFuture;
+    private ScheduledFuture<?> scheduledFuture;
     private AtomicBoolean start = new AtomicBoolean(false);
     private ClientNotifier clientNotifier;
     private JobTrackerApplication application;
@@ -39,7 +39,8 @@ public class FeedbackJobSendChecker {
      *
      * @return
      */
-    private boolean isStart() {
+    @SuppressWarnings("unused")
+	private boolean isStart() {
         return start.get();
     }
 
@@ -164,7 +165,10 @@ public class FeedbackJobSendChecker {
     }
 
     private class TaskTrackerJobResultWrapper extends TaskTrackerJobResult {
-        private String id;
+		
+    	private static final long serialVersionUID = 6257259684477618571L;
+    	
+		private String id;
 
         public String getId() {
             return id;

lts-logger/lts-logger-api/src/main/java/com/lts/biz/logger/JobLogException.java

@@ -5,7 +5,9 @@ package com.lts.biz.logger;
  */
 public class JobLogException extends RuntimeException {
 
-    public JobLogException() {
+	private static final long serialVersionUID = -7907389604614654285L;
+
+	public JobLogException() {
         super();
     }
 
@@ -21,7 +23,4 @@ public class JobLogException extends RuntimeException {
         super(cause);
     }
 
-    protected JobLogException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-logger/lts-logger-api/src/main/java/com/lts/biz/logger/JobLoggerDelegate.java

@@ -34,7 +34,8 @@ public class JobLoggerDelegate implements JobLogger {
     private JobLogger jobLogger;
     private boolean lazyLog = false;
     private ScheduledExecutorService executor;
-    private ScheduledFuture scheduledFuture;
+    @SuppressWarnings("unused")
+	private ScheduledFuture<?> scheduledFuture;
     private BlockingQueue<JobLogPo> memoryQueue;
     // 日志批量刷盘数量
     private int batchFlushSize = 100;

lts-queue/lts-queue-api/src/main/java/com/lts/queue/AbstractPreLoader.java

@@ -25,7 +25,8 @@ public abstract class AbstractPreLoader implements PreLoader {
     // 加载的信号
     private ConcurrentHashSet<String> LOAD_SIGNAL = new ConcurrentHashSet<String>();
     private ScheduledExecutorService LOAD_EXECUTOR_SERVICE = Executors.newSingleThreadScheduledExecutor();
-    private ScheduledFuture<?> scheduledFuture;
+    @SuppressWarnings("unused")
+	private ScheduledFuture<?> scheduledFuture;
     private AtomicBoolean start = new AtomicBoolean(false);
     private String FORCE_PREFIX = "force_"; // 强制加载的信号
 

lts-queue/lts-queue-api/src/main/java/com/lts/queue/JobPriorityBlockingQueue.java

@@ -10,6 +10,7 @@ import java.util.concurrent.locks.ReentrantLock;
  * 主要做了一个去重的操作，当时同一个任务的时候，会覆盖
  * @author Robert HG (254963746@qq.com) on 10/19/15.
  */
+@SuppressWarnings("unchecked")
 public class JobPriorityBlockingQueue {
 
     private final ReentrantLock lock;
@@ -103,7 +104,7 @@ public class JobPriorityBlockingQueue {
         }
     }
 
-    private <E> void siftDownUsingComparator(int k, E x, Object[] array,
+	private <E> void siftDownUsingComparator(int k, E x, Object[] array,
                                              int n,
                                              Comparator<? super E> cmp) {
         if (n > 0) {

lts-queue/lts-queue-api/src/main/java/com/lts/queue/PreLoaderFactory.java

@@ -4,7 +4,6 @@ import com.lts.core.Application;
 import com.lts.core.cluster.Config;
 import com.lts.core.extension.Adaptive;
 import com.lts.core.extension.SPI;
-import com.lts.queue.domain.JobPo;
 
 /**
  * @author Robert HG (254963746@qq.com) on 8/14/15.

lts-queue/lts-queue-api/src/main/java/com/lts/queue/domain/JobPo.java

@@ -1,7 +1,6 @@
 package com.lts.queue.domain;
 
 import com.lts.core.commons.utils.JSONUtils;
-import com.lts.core.support.SystemClock;
 
 import java.util.Map;
 

lts-queue/lts-queue-api/src/main/java/com/lts/queue/exception/DuplicateJobException.java

@@ -6,7 +6,9 @@ package com.lts.queue.exception;
  */
 public class DuplicateJobException extends RuntimeException {
 
-    public DuplicateJobException() {
+	private static final long serialVersionUID = 2049995998886965479L;
+
+	public DuplicateJobException() {
         super();
     }
 

lts-queue/lts-queue-api/src/main/java/com/lts/queue/exception/JobQueueException.java

@@ -5,7 +5,9 @@ package com.lts.queue.exception;
  */
 public class JobQueueException extends RuntimeException {
 
-    public JobQueueException(String message) {
+	private static final long serialVersionUID = -4879333207487958676L;
+
+	public JobQueueException(String message) {
         super(message);
     }
 

lts-spring/src/main/java/com/lts/spring/JobClientFactoryBean.java

@@ -6,6 +6,7 @@ import com.lts.jobclient.JobClient;
 import com.lts.jobclient.RetryJobClient;
 import com.lts.jobclient.support.JobCompletedHandler;
 import com.lts.tasktracker.TaskTracker;
+
 import org.springframework.beans.factory.DisposableBean;
 import org.springframework.beans.factory.FactoryBean;
 import org.springframework.beans.factory.InitializingBean;
@@ -17,10 +18,11 @@ import java.util.Properties;
  * JobClient Spring Bean 工厂类
  * @author Robert HG (254963746@qq.com) on 8/4/15.
  */
+@SuppressWarnings("rawtypes")
 public class JobClientFactoryBean implements FactoryBean<JobClient>,
         InitializingBean, DisposableBean {
 
-    private JobClient jobClient;
+	private JobClient jobClient;
     private boolean started;
     /**
      * 集群名称

lts-spring/src/main/java/com/lts/spring/TaskTrackerAnnotationFactoryBean.java

@@ -8,13 +8,13 @@ import com.lts.spring.tasktracker.JobDispatcher;
 import com.lts.tasktracker.TaskTracker;
 import com.lts.tasktracker.runner.JobRunner;
 import com.lts.tasktracker.runner.RunnerFactory;
+
 import org.springframework.beans.BeansException;
 import org.springframework.beans.factory.DisposableBean;
 import org.springframework.beans.factory.FactoryBean;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.beans.factory.support.BeanDefinitionBuilder;
 import org.springframework.beans.factory.support.DefaultListableBeanFactory;
-import org.springframework.beans.factory.support.RootBeanDefinition;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
 import org.springframework.context.ConfigurableApplicationContext;
@@ -28,6 +28,7 @@ import java.util.Properties;
  *
  * @author Robert HG (254963746@qq.com) on 8/4/15.
  */
+@SuppressWarnings("rawtypes")
 public class TaskTrackerAnnotationFactoryBean implements FactoryBean<TaskTracker>, ApplicationContextAware,
         InitializingBean, DisposableBean {
 
@@ -57,7 +58,7 @@ public class TaskTrackerAnnotationFactoryBean implements FactoryBean<TaskTracker
     /**
      * 任务执行类
      */
-    private Class jobRunnerClass;
+	private Class jobRunnerClass;
     /**
      * 业务日志级别
      */
@@ -106,7 +107,8 @@ public class TaskTrackerAnnotationFactoryBean implements FactoryBean<TaskTracker
                 StringUtils.format("jobRunnerClass should be implements {}.", JobRunner.class.getName()));
     }
 
-    @Override
+    @SuppressWarnings("unchecked")
+	@Override
     public void afterPropertiesSet() throws Exception {
 
         checkProperties();

lts-spring/src/main/java/com/lts/spring/TaskTrackerXmlFactoryBean.java

@@ -7,11 +7,9 @@ import com.lts.core.listener.MasterChangeListener;
 import com.lts.tasktracker.TaskTracker;
 import com.lts.tasktracker.runner.JobRunner;
 import com.lts.tasktracker.runner.RunnerFactory;
-import org.springframework.beans.BeansException;
 import org.springframework.beans.factory.DisposableBean;
 import org.springframework.beans.factory.FactoryBean;
 import org.springframework.beans.factory.InitializingBean;
-import org.springframework.context.ApplicationContext;
 
 import java.util.Map;
 import java.util.Properties;

lts-spring/src/main/java/com/lts/spring/tasktracker/JobDispatchException.java

@@ -5,7 +5,9 @@ package com.lts.spring.tasktracker;
  */
 public class JobDispatchException extends Exception{
 
-    public JobDispatchException() {
+	private static final long serialVersionUID = -99670791735250890L;
+
+	public JobDispatchException() {
         super();
     }
 

lts-spring/src/test/java/LTSSpringConfig.java

@@ -4,6 +4,7 @@ import com.lts.spring.JobClientFactoryBean;
 import com.lts.spring.JobTrackerFactoryBean;
 import com.lts.spring.TaskTrackerAnnotationFactoryBean;
 import com.lts.tasktracker.TaskTracker;
+
 import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
@@ -26,7 +27,8 @@ public class LTSSpringConfig implements ApplicationContextAware {
         this.applicationContext = applicationContext;
     }
 
-    @Bean(name = "jobClient")
+    @SuppressWarnings("rawtypes")
+	@Bean(name = "jobClient")
     public JobClient getJobClient() throws Exception {
         JobClientFactoryBean factoryBean = new JobClientFactoryBean();
         // TODO 设置一些配置 属性

lts-startup/lts-startup-jobtracker/src/main/java/com/lts/startup/CfgException.java

@@ -5,7 +5,9 @@ package com.lts.startup;
  */
 public class CfgException extends Exception {
 
-    public CfgException() {
+	private static final long serialVersionUID = -661377294271386745L;
+
+	public CfgException() {
         super();
     }
 

lts-startup/lts-startup-tasktracker/src/main/java/com/lts/startup/CfgException.java

@@ -5,7 +5,9 @@ package com.lts.startup;
  */
 public class CfgException extends Exception {
 
-    public CfgException() {
+	private static final long serialVersionUID = -661377294271386745L;
+
+	public CfgException() {
         super();
     }
 

lts-startup/lts-startup-tasktracker/src/main/java/com/lts/startup/DefaultStartup.java

@@ -10,7 +10,8 @@ import java.util.Map;
  */
 public class DefaultStartup {
 
-    public static TaskTracker start(TaskTrackerCfg cfg) {
+    @SuppressWarnings("unchecked")
+	public static TaskTracker start(TaskTrackerCfg cfg) {
 
         final TaskTracker taskTracker = new TaskTracker();
         taskTracker.setJobRunnerClass(cfg.getJobRunnerClass());

lts-startup/lts-startup-tasktracker/src/main/java/com/lts/startup/SpringStartup.java

@@ -1,6 +1,7 @@
 package com.lts.startup;
 
 import com.lts.tasktracker.TaskTracker;
+
 import org.springframework.context.ApplicationContext;
 
 /**
@@ -8,7 +9,8 @@ import org.springframework.context.ApplicationContext;
  */
 public class SpringStartup {
 
-    public static TaskTracker start(String cfgPath) {
+    @SuppressWarnings("resource")
+	public static TaskTracker start(String cfgPath) {
 
         System.setProperty("lts.tasktracker.cfg.path", cfgPath);
 

lts-startup/lts-startup-tasktracker/src/main/java/com/lts/startup/TaskTrackerCfg.java

@@ -9,6 +9,7 @@ import java.util.Map;
  *
  * @author Robert HG (254963746@qq.com) on 9/1/15.
  */
+@SuppressWarnings("rawtypes")
 public class TaskTrackerCfg {
 
     private String registryAddress;
@@ -21,7 +22,7 @@ public class TaskTrackerCfg {
 
     private int workThreads;
 
-    private Class jobRunnerClass;
+	private Class jobRunnerClass;
 
     private String dataPath;
 

lts-tasktracker/src/main/java/com/lts/tasktracker/domain/TaskTrackerApplication.java

@@ -29,7 +29,7 @@ public class TaskTrackerApplication extends Application{
     /**
      * 执行任务的class
      */
-    private Class jobRunnerClass;
+    private Class<?> jobRunnerClass;
 
     public StopWorkingMonitor getStopWorkingMonitor() {
         return stopWorkingMonitor;
@@ -55,11 +55,11 @@ public class TaskTrackerApplication extends Application{
         this.bizLogLevel = bizLogLevel;
     }
 
-    public Class getJobRunnerClass() {
+    public Class<?> getJobRunnerClass() {
         return jobRunnerClass;
     }
 
-    public void setJobRunnerClass(Class jobRunnerClass) {
+    public void setJobRunnerClass(Class<?> jobRunnerClass) {
         this.jobRunnerClass = jobRunnerClass;
     }
 

lts-tasktracker/src/main/java/com/lts/tasktracker/expcetion/NoAvailableJobRunnerException.java

@@ -6,7 +6,9 @@ package com.lts.tasktracker.expcetion;
  */
 public class NoAvailableJobRunnerException extends Exception{
 
-    public NoAvailableJobRunnerException() {
+	private static final long serialVersionUID = 5317008601154858522L;
+
+	public NoAvailableJobRunnerException() {
         super();
     }
 
@@ -22,7 +24,4 @@ public class NoAvailableJobRunnerException extends Exception{
         super(cause);
     }
 
-    protected NoAvailableJobRunnerException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
-        super(message, cause, enableSuppression, writableStackTrace);
-    }
 }

lts-tasktracker/src/main/java/com/lts/tasktracker/monitor/StopWorkingMonitor.java

@@ -27,7 +27,7 @@ public class StopWorkingMonitor {
     private TaskTrackerApplication application;
     private AtomicBoolean start = new AtomicBoolean(false);
     private final ScheduledExecutorService SCHEDULED_CHECKER = Executors.newScheduledThreadPool(1);
-    private ScheduledFuture scheduledFuture;
+    private ScheduledFuture<?> scheduledFuture;
     private String ecSubscriberName = StopWorkingMonitor.class.getSimpleName();
     private EventSubscriber eventSubscriber;
     private Long offlineTimestamp = null;