Skip to content
This repository was archived by the owner on Jan 3, 2023. It is now read-only.

Commit 2cc104e

Browse files
authored
Fix #1459, Fix stop cmdlet error (#1460)
1 parent 6c01665 commit 2cc104e

File tree

1 file changed

+6
-2
lines changed
  • smart-engine/src/main/java/org/smartdata/server/engine/cmdlet/agent

1 file changed

+6
-2
lines changed

smart-engine/src/main/java/org/smartdata/server/engine/cmdlet/agent/AgentMaster.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -278,8 +278,12 @@ private boolean handleClientMessage(Object message) {
278278
return true;
279279
} else if (message instanceof StopCmdlet) {
280280
long cmdletId = ((StopCmdlet) message).getCmdletId();
281-
dispatches.get(cmdletId).tell(message, getSelf());
282-
getSender().tell("Succeed", getSelf());
281+
if (dispatches.containsKey(cmdletId)) {
282+
dispatches.get(cmdletId).tell(message, getSelf());
283+
getSender().tell("Succeed", getSelf());
284+
} else {
285+
getSender().tell("NotFound", getSelf());
286+
}
283287
return true;
284288
} else {
285289
return false;

0 commit comments

Comments
 (0)