com.netflix.genie.core.services.impl

Class LocalJobKillServiceImpl

java.lang.Object

com.netflix.genie.core.services.impl.LocalJobKillServiceImpl

All Implemented Interfaces:

JobKillService

public class LocalJobKillServiceImpl
extends java.lang.Object
implements JobKillService

Implementation of the JobKillService interface which attempts to kill jobs running on the local node.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
LocalJobKillServiceImpl(java.lang.String hostName, JobSearchService jobSearchService, org.apache.commons.exec.Executor executor, boolean runAsUser, org.springframework.context.ApplicationEventPublisher eventPublisher, org.springframework.core.io.Resource genieWorkingDir, com.fasterxml.jackson.databind.ObjectMapper objectMapper) Constructor.

Method Summary

Modifier and Type	Method and Description
void	killJob(java.lang.String id, java.lang.String reason) Kill the job with the given id if possible.
void	onKillJobEvent(KillJobEvent event) Listen for job kill events from within the system as opposed to on calls from users directly to killJob.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalJobKillServiceImpl

public LocalJobKillServiceImpl(@NotBlank
                               java.lang.String hostName,
                               @NotNull
                               JobSearchService jobSearchService,
                               @NotNull
                               org.apache.commons.exec.Executor executor,
                               boolean runAsUser,
                               @NotNull
                               org.springframework.context.ApplicationEventPublisher eventPublisher,
                               @NotNull
                               org.springframework.core.io.Resource genieWorkingDir,
                               @NotNull
                               com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Constructor.

Parameters:

hostName - The name of the host this Genie node is running on

jobSearchService - The job search service to use to locate job information

executor - The executor to use to run system processes

runAsUser - True if jobs are run as the user who submitted the job

eventPublisher - The system event publisher to use

genieWorkingDir - The working directory where all job directories are created.

objectMapper - The Jackson ObjectMapper used to serialize from/to JSON

Method Detail

killJob

public void killJob(@NotBlank(message="No id entered. Unable to kill job.")
                    java.lang.String id,
                    @NotBlank(message="No reason provided.")
                    java.lang.String reason)
             throws GenieException

Kill the job with the given id if possible. Should publish a JobFinishedEvent when done.

Specified by:

killJob in interface JobKillService

Parameters:

id - id of job to kill

reason - brief reason for requesting the job be killed

Throws:

GenieException - if there is an error

onKillJobEvent

@EventListener
public void onKillJobEvent(@NotNull
                                          KillJobEvent event)
                                   throws GenieException

Listen for job kill events from within the system as opposed to on calls from users directly to killJob.

Specified by:

onKillJobEvent in interface JobKillService

Parameters:

event - The KillJobEvent

Throws:

GenieException - On error