Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion job-server/src/spark.jobserver/io/JobFileDAO.scala
Original file line number Diff line number Diff line change
Expand Up @@ -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(':', '_')
Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Since we will need to register these with executors in most case (SnappyExecutor), will it not be better to register these with the name provided here to install-jar and then use replace-jar for subsequent calls? The additional handling of URLs here and in snappydata looks dicey to me.


override def saveJobInfo(jobInfo: JobInfo) {
writeJobInfo(jobsOutputStream, jobInfo)
Expand Down