From 49cf0f8eb4d1fd8477ea337a5f43b35b184b1308 Mon Sep 17 00:00:00 2001 From: nthanvi Date: Thu, 21 Jul 2016 11:18:10 +0530 Subject: [PATCH] adding a suffix to jar name A suffix is added to jarname so that executors can identify that job server has provided the updated jar file. --- job-server/src/spark.jobserver/io/JobFileDAO.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/job-server/src/spark.jobserver/io/JobFileDAO.scala b/job-server/src/spark.jobserver/io/JobFileDAO.scala index 9cd4bee2a..21494fafb 100644 --- a/job-server/src/spark.jobserver/io/JobFileDAO.scala +++ b/job-server/src/spark.jobserver/io/JobFileDAO.scala @@ -135,7 +135,7 @@ class JobFileDAO(config: Config) extends JobDAO { new File(rootDir, createJarName(appName, uploadTime) + ".jar").getAbsolutePath private def createJarName(appName: String, uploadTime: DateTime): String = - appName + "-" + uploadTime.toString().replace(':', '_') + appName + "_SNAPPY_JOB_SERVER_JAR_" + uploadTime.toString().replace(':', '_') override def saveJobInfo(jobInfo: JobInfo) { writeJobInfo(jobsOutputStream, jobInfo)