1. reset network flag when onError occurs. 2. remove unless import

skywalking-network/src/main/java/com/a/eye/skywalking/network/listener/client/StorageClientListener.java

 package com.a.eye.skywalking.network.listener.client;
 
-import com.a.eye.skywalking.network.grpc.SendResult;
-
 /**
  * Created by wusheng on 2016/11/27.
  */

skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/client/Agent2RoutingClient.java

@@ -91,7 +91,11 @@ public class Agent2RoutingClient extends Thread {
                         spanStorageClient.sendACKSpan(ackData);
 
                         while (!listener.isBatchFinished()) {
-                            LockSupport.parkNanos(1);
+                            try {
+                            Thread.sleep(10L);
+                            } catch (InterruptedException e) {
+
+                            }
                         }
                     } else {
                         try {

skywalking-storage-center/skywalking-routing/src/main/java/com/a/eye/skywalking/routing/disruptor/AbstractRouteSpanEventHandler.java

@@ -34,6 +34,7 @@ public abstract class AbstractRouteSpanEventHandler<T> implements EventHandler<T
         SpanStorageClient spanStorageClient = client.newSpanStorageClient(new StorageClientListener() {
             @Override
             public void onError(Throwable throwable) {
+                previousSendFinish = true;
                 HealthCollector.getCurrentHeathReading(getExtraId()).updateData(HeathReading.ERROR, "Failed to send  span. error message :" + throwable.getMessage());
             }