Handle nullptr on killJobRequest requestor (#128)

Netflix · Nov 11, 2021 · 28ce730 · 28ce730
1 parent 3c163fa
commit 28ce730
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...tis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java b/...tis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java
@@ -1716,7 +1716,15 @@ public void onJobKillRequest(KillJobRequest req) {
             jobInfo.get().jobActor.tell(req, getSelf());
         } else {
             logger.info("Job {} not found", req.jobId.getId() );
-            req.requestor.tell(new JobClusterManagerProto.KillJobResponse(req.requestId, CLIENT_ERROR_NOT_FOUND, JobState.Noop, "Job " + req.jobId + " not found", req.jobId, req.user), getSelf());
+            if (req.requestor != null) {
+                req.requestor.tell(
+                        new JobClusterManagerProto.KillJobResponse(
+                                req.requestId,
+                                CLIENT_ERROR_NOT_FOUND,
+                                JobState.Noop,
+                                "Job " + req.jobId + " not found", req.jobId, req.user),
+                        getSelf());
+            }
         }
     }