Selaa lähdekoodia

HUE-2481 [oozie] handle escaped = in jo.properties when submitting from hdfs

krish 11 vuotta sitten
vanhempi
commit
f435f9e3f7
1 muutettua tiedostoa jossa 3 lisäystä ja 2 poistoa
  1. 3 2
      desktop/libs/liboozie/src/liboozie/submittion.py

+ 3 - 2
desktop/libs/liboozie/src/liboozie/submittion.py

@@ -18,6 +18,7 @@
 import errno
 import logging
 import os
+import re
 import time
 
 from django.utils.translation import ugettext as _
@@ -178,8 +179,8 @@ class Submission(object):
     parameters = dict([(var, '') for var in find_variables(xml, include_named=False) if not self._is_coordinator() or var not in DATASET_FREQUENCY])
 
     if properties:
-      parameters.update(dict([line.strip().split('=')
-                              for line in properties.split('\n') if not line.startswith('#') and len(line.strip().split('=')) == 2]))
+      parameters.update(dict([re.split(r'(?<!\\)=', line.strip())
+                              for line in properties.split('\n') if not line.startswith('#') and len(re.split(r'(?<!\\)=', line.strip())) == 2]))
     return parameters
 
   def _update_properties(self, jobtracker_addr, deployment_dir=None):