From eea062ce8e43eaa20d279bf5dbc7e468aa0a9c2f Mon Sep 17 00:00:00 2001
From: huangsimin <474420502@qq.com>
Date: Tue, 26 Jul 2022 17:52:58 +0800
Subject: [PATCH] =?UTF-8?q?=E5=87=8F=E5=B0=91=E5=9B=9E=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/yuandian/dataflow/controller/PacketsProcessor.java | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

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);
                     }