Changed Shutdown hook priority to 20

apache · Sep 13, 2014 · 54eb68f · 54eb68f
1 parent 2f0aee3
commit 54eb68f
Showing 1 changed file with 4 additions and 1 deletion.
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
@@ -103,8 +103,11 @@ private[spark] class ApplicationMaster(args: ApplicationMasterArguments,
         }
       }
     }
+
     // Use higher priority than FileSystem.
-    ShutdownHookManager.get().addShutdownHook(cleanupHook, FileSystem.SHUTDOWN_HOOK_PRIORITY + 1)
+    val priority = 20
+    assert(priority > FileSystem.SHUTDOWN_HOOK_PRIORITY)
+    ShutdownHookManager.get().addShutdownHook(cleanupHook, 20)
 
     // 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