Set shutdown_grace_period for mesos agent.

ddzzj · Jan 23, 2019 · 6dfe760 · 6dfe760
1 parent ee77325
commit 6dfe760
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dpark/schedule.py b/dpark/schedule.py
@@ -1072,6 +1072,7 @@ def getExecutorInfo(self, framework_id):
         )
         info.executor_id.value = env.get('DPARK_ID', 'default')
         info.command.environment.variables = variables = []
+        info.shutdown_grace_period.nanoseconds = 5 * (10 ** 9)
 
         v = Dict()
         variables.append(v)