@@ -35,4 +35,9 @@ def oozie():
File(os.path.join(params.oozie_conf_dir, "oozie-env.cmd"),
owner=params.oozie_user,
content=InlineTemplate(params.oozie_env_cmd_template)
+ )
+
+ Directory( params.oozie_tmp_dir,
+ owner = params.oozie_user,
+ recursive = True,
)
@@ -51,6 +51,8 @@ class OozieServer(Script):
import params
env.set_params(params)
self.configure(env)
+ cmd = format("cmd /C \"cd /d {oozie_tmp_dir} && {oozie_home}\\bin\\ooziedb.cmd create -sqlfile oozie.sql -run\"")
+ Execute( cmd, user = params.oozie_user, ignore_failures = True )
Service(service_mapping.oozie_server_win_service_name, action="start")
def stop(self, env):
@@ -29,5 +29,6 @@ oozie_root = os.environ['OOZIE_ROOT']
oozie_home = os.environ['OOZIE_HOME']
oozie_conf_dir = os.path.join(oozie_home,'conf')
oozie_user = "hadoop"
+oozie_tmp_dir = "c:\\hadoop\\temp\\oozie"
oozie_env_cmd_template = config['configurations']['oozie-env']['content']