You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Jake Maes (JIRA)" <ji...@apache.org> on 2017/04/03 16:51:42 UTC

[jira] [Resolved] (SAMZA-1089) JobRunner should support kill and status commands.

     [ https://issues.apache.org/jira/browse/SAMZA-1089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jake Maes resolved SAMZA-1089.
------------------------------
       Resolution: Fixed
    Fix Version/s: 0.13.0

Issue resolved by pull request 106
[https://github.com/apache/samza/pull/106]

> JobRunner should support kill and status commands.
> --------------------------------------------------
>
>                 Key: SAMZA-1089
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1089
>             Project: Samza
>          Issue Type: Task
>            Reporter: Jake Maes
>            Assignee: Jake Maes
>             Fix For: 0.13.0
>
>
> The JobRunner is the central place to launch Samza jobs. We use run-job.sh to invoke the JobRunner, which then launches the job as described here:
> http://samza.apache.org/learn/documentation/0.11/jobs/job-runner.html
> Note that the JobRunner works for any job that implements the StreamJob interface, so it works with YarnJob, ProcessJob, and so on.
> However, to kill or get the status for a job, we only have a set of YARN-specific scripts. 
> Since the StreamJobs all implement the kill() and getStatus() methods, there's no reason we can't similarly leverage the StreamJob abstraction to perform these operations as well. 
> The proposal is to update JobRunner to support all 3 commands. 
> The benefits are:
> 1. A common abstract way to start, stop, and get status for any type of StreamJob.
> 2. For features like multistage (samza-1041), this will be a much easier way to collectively manage a set of processors as separate (e.g. YARN) applications



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)