Jelajahi Sumber

[pig] Fix wrong Fs impersonation

Romain Rigaux 12 tahun lalu
induk
melakukan
9d42c9c
1 mengubah file dengan 1 tambahan dan 1 penghapusan
  1. 1 1
      apps/pig/src/pig/api.py

+ 1 - 1
apps/pig/src/pig/api.py

@@ -79,7 +79,7 @@ class OozieApi:
     Workflow.objects.initialize(workflow, self.fs)
 
     script_path = workflow.deployment_dir + '/script.pig'
-    self.fs.create(script_path, data=pig_script.dict['script'])
+    self.fs.do_as_user(self.user.username, self.fs.create, script_path, data=pig_script.dict['script'])
 
     files = []
     archives = []