Unverified Commit a807916a authored by Keshav Prasad's avatar Keshav Prasad
Browse files

fix: ED-573 jenkins job to kill spark jobs


Signed-off-by: default avatarKeshav Prasad <keshavprasadms@gmail.com>
Showing with 63 additions and 0 deletions
+63 -0
---
- hosts: spark
become: yes
tasks:
- name: get pids of job manager which may be orphaned
shell: ps -ef | grep [j]ob. | awk '{print $2}'
register: pids_of_jobmanager
- name: kill the orphan job manager pids
shell: "kill -9 {{ item | int }}"
with_items:
- "{{ pids_of_jobmanager.stdout_lines }}"
@Library('deploy-conf') _
node() {
try {
String ANSI_GREEN = "\u001B[32m"
String ANSI_NORMAL = "\u001B[0m"
String ANSI_BOLD = "\u001B[1m"
String ANSI_RED = "\u001B[31m"
String ANSI_YELLOW = "\u001B[33m"
stage('checkout public repo') {
folder = new File("$WORKSPACE/.git")
if (folder.exists())
{
println "Found .git folder. Clearing it.."
sh'git clean -fxd'
}
checkout scm
}
ansiColor('xterm') {
stage('deploy'){
values = [:]
currentWs = sh(returnStdout: true, script: 'pwd').trim()
envDir = sh(returnStdout: true, script: "echo $JOB_NAME").split('/')[-3].trim()
module = sh(returnStdout: true, script: "echo $JOB_NAME").split('/')[-2].trim()
jobName = sh(returnStdout: true, script: "echo $JOB_NAME").split('/')[-1].trim()
ansiblePlaybook = "${currentWs}/ansible/kill_spark_jobs.yaml"
ansibleExtraArgs = "-v"
values.put('currentWs', currentWs)
values.put('env', envDir)
values.put('module', module)
values.put('jobName', jobName)
values.put('ansiblePlaybook', ansiblePlaybook)
values.put('ansibleExtraArgs', ansibleExtraArgs)
println values
ansible_playbook_run(values)
currentBuild.result = 'SUCCESS'
currentBuild.description = "Private: ${params.private_branch}, Public: ${params.branch_or_tag}"
}
}
summary()
}
catch (err) {
currentBuild.result = 'FAILURE'
throw err
}
finally {
slack_notify(currentBuild.result)
email_notify()
}
}
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment