diff --git a/src/main/java/com/yuandian/dataflow/controller/PacketsProcessor.java b/src/main/java/com/yuandian/dataflow/controller/PacketsProcessor.java
index f2db24b..e9f6d0a 100644
--- a/src/main/java/com/yuandian/dataflow/controller/PacketsProcessor.java
+++ b/src/main/java/com/yuandian/dataflow/controller/PacketsProcessor.java
@@ -67,17 +67,16 @@ public class PacketsProcessor implements RpcProcessor<PacketsProcessor.PacketsRe
               
                 work.setTaskQueueSize( work.getTaskQueueSize() - request.packets.size());
                 work.setUpdateAt(Instant.now());
-                log.debug("workerState taskQueueSize: {} psize: {}", work.getTaskQueueSize(), request.packets.size());
+                log.debug("workerState taskQueueSize: {} psize: {} state {}", work.getTaskQueueSize(), request.packets.size(), state.getWorkers().size());
                 var op = new Operate(OperateType.PUT);
                 op.setValue(work);
-
                 Operate.CallOperate(op, new OperateClosure() {
-
                     @Override
                     public void run(Status status) {
                         log.info("{}", this.getResponse());
                         var resp = new RaftResponse();
-                        resp.setRedirect(StateServerFactory.getStateServer().getNode().getLeaderId());
+                        resp.setSuccess(true);
+                        // resp.setRedirect(StateServerFactory.getStateServer().getNode().getLeaderId());
                         rpcCtx.sendResponse(resp);
                     }