@@ -68,7 +68,8 @@ def service(componentName, action='start', serviceName='yarn'):
action="delete")
elif action == 'refreshQueues':
- refresh_cmd = format("export HADOOP_LIBEXEC_DIR={hadoop_libexec_dir} && {yarn_container_bin}/yarn rmadmin -refreshQueues")
+ rm_kinit_cmd = params.rm_kinit_cmd
+ refresh_cmd = format("{rm_kinit_cmd} export HADOOP_LIBEXEC_DIR={hadoop_libexec_dir} && {yarn_container_bin}/yarn rmadmin -refreshQueues")
Execute(refresh_cmd,
user=usr,