[Bug] The origin future must be null

coderzc commented 1 year ago

Bug Type (问题类型)

exception / error (运行异常)

Before submit

[X] 我已经确认现有的 Server-Issues 与 Computer-Issues 中没有相同 / 重复问题

Environment (环境信息)

CI

Expected & Actual behavior (期望与实际表现)

https://github.com/apache/incubator-hugegraph-computer/actions/runs/3552615255/jobs/5967635439#step:14:1110

Error: -26 06:47:42 [Thread-14] [ERROR] c.b.h.c.s.i.SenderIntegrateTest - Failed to execute worker service
com.baidu.hugegraph.computer.core.common.exception.ComputerException: The origin future must be null
    at com.baidu.hugegraph.computer.core.sender.QueuedMessageSender$WorkerChannel.newFuture(QueuedMessageSender.java:236) ~[classes/:?]
    at com.baidu.hugegraph.computer.core.sender.QueuedMessageSender.send(QueuedMessageSender.java:90) ~[classes/:?]
    at com.baidu.hugegraph.computer.core.sender.MessageSendManager.sendControlMessageToWorkers(MessageSendManager.java:267) ~[classes/:?]
    at com.baidu.hugegraph.computer.core.sender.MessageSendManager.startSend(MessageSendManager.java:155) ~[classes/:?]
    at com.baidu.hugegraph.computer.core.input.WorkerInputManager.loadGraph(WorkerInputManager.java:88) ~[classes/:?]
    at com.baidu.hugegraph.computer.core.worker.WorkerService.inputstep(WorkerService.java:356) ~[classes/:?]
    at com.baidu.hugegraph.computer.core.worker.WorkerService.execute(WorkerService.java:219) ~[classes/:?]
    at com.baidu.hugegraph.computer.suite.integrate.SenderIntegrateTest.lambda$testMultiWorkers$3(SenderIntegrateTest.java:183) ~[classes/:?]
    at java.lang.Thread.run(Thread.java:829) ~[?:?]