Modified the priority for AM's shutdown hook

sarutak · sarutak · commit 4c5cb938db38 · 2014-09-05T15:46:20.000+09:00
diff --git a/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala b/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala
@@ -104,7 +104,7 @@ private[spark] class ApplicationMaster(args: ApplicationMasterArguments,
       }
     }
     // Use higher priority than FileSystem.
-    ShutdownHookManager.get().addShutdownHook(cleanupHook, FileSystem.SHUTDOWN_HOOK_PRIORITY - 1)
+    ShutdownHookManager.get().addShutdownHook(cleanupHook, FileSystem.SHUTDOWN_HOOK_PRIORITY + 1)
 
     // Call this to force generation of secret so it gets populated into the
     // Hadoop UGI. This has to happen before the startUserClass which does a

Original file line number	Diff line number	Diff line change
`@@ -104,7 +104,7 @@ private[spark] class ApplicationMaster(args: ApplicationMasterArguments,`
`104`	`104`	`}`
`105`	`105`	`}`
`106`	`106`	`// Use higher priority than FileSystem.`
`107`		`- ShutdownHookManager.get().addShutdownHook(cleanupHook, FileSystem.SHUTDOWN_HOOK_PRIORITY - 1)`
	`107`	`+ ShutdownHookManager.get().addShutdownHook(cleanupHook, FileSystem.SHUTDOWN_HOOK_PRIORITY + 1)`
`108`	`108`
`109`	`109`	`// Call this to force generation of secret so it gets populated into the`
`110`	`110`	`// Hadoop UGI. This has to happen before the startUserClass which does a`