From 7c41ebc93c75efbe28b660ce4f3b4ccb0908c370 Mon Sep 17 00:00:00 2001
From: fanqq <fanqq@Ctrip.com>
Date: Fri, 11 Sep 2015 17:11:34 +0800
Subject: [PATCH] fix

---
 .../java/com/ctrip/zeus/executor/impl/TaskWorkerImpl.java  | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/ctrip/zeus/executor/impl/TaskWorkerImpl.java b/src/main/java/com/ctrip/zeus/executor/impl/TaskWorkerImpl.java
index 2326abf4..d985b99d 100644
--- a/src/main/java/com/ctrip/zeus/executor/impl/TaskWorkerImpl.java
+++ b/src/main/java/com/ctrip/zeus/executor/impl/TaskWorkerImpl.java
@@ -9,7 +9,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Component;
 
-import javax.annotation.Resource;
+import javax.annotation.Resource;   
 
 /**
  * Created by fanqq on 2015/7/31.
@@ -22,6 +22,7 @@ public class TaskWorkerImpl implements TaskWorker {
     @Resource
     TaskExecutor taskExecutor;
     Logger logger = LoggerFactory.getLogger(this.getClass());
+    private static int initFailCount = 0;
     @Override
     public void execute() {
         try {
@@ -42,7 +43,11 @@ public class TaskWorkerImpl implements TaskWorker {
         Slb slb = slbRepository.getBySlbServer(S.getIp());
         if (slb != null && slb.getId()!=null){
             workerSlbId = slb.getId();
+            initFailCount = 0;
         }else{
+            if (++initFailCount > 3){
+                workerSlbId = null;
+            }
             logger.error("Can Not Found Slb by Local Ip. TaskExecutor is not working!");
         }
     }