ambari-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vbrodets...@apache.org
Subject ambari git commit: AMBARI-13089. Ambari seems to strip %Y %M %D, etc partitioning options from Flume output paths.(vbrodetskyi)
Date Wed, 07 Oct 2015 14:27:47 GMT
Repository: ambari
Updated Branches:
  refs/heads/branch-2.0.maint 2765b52d8 -> ef5bca629


AMBARI-13089. Ambari seems to strip %Y %M %D, etc partitioning options from Flume output paths.(vbrodetskyi)


Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/ef5bca62
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/ef5bca62
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/ef5bca62

Branch: refs/heads/branch-2.0.maint
Commit: ef5bca629c07b7296494f8230257fbd9e85aaffd
Parents: 2765b52
Author: Vitaly Brodetskyi <vbrodetskyi@hortonworks.com>
Authored: Wed Oct 7 17:26:01 2015 +0300
Committer: Vitaly Brodetskyi <vbrodetskyi@hortonworks.com>
Committed: Wed Oct 7 17:26:01 2015 +0300

----------------------------------------------------------------------
 .../common-services/FLUME/1.4.0.2.0/package/scripts/flume.py      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ambari/blob/ef5bca62/ambari-server/src/main/resources/common-services/FLUME/1.4.0.2.0/package/scripts/flume.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/FLUME/1.4.0.2.0/package/scripts/flume.py
b/ambari-server/src/main/resources/common-services/FLUME/1.4.0.2.0/package/scripts/flume.py
index ee1ed00..0b2787d 100644
--- a/ambari-server/src/main/resources/common-services/FLUME/1.4.0.2.0/package/scripts/flume.py
+++ b/ambari-server/src/main/resources/common-services/FLUME/1.4.0.2.0/package/scripts/flume.py
@@ -208,7 +208,8 @@ def build_flume_topology(content):
     if 0 != len(rline) and not rline.startswith('#'):
       pair = rline.split('=')
       lhs = pair[0].strip()
-      rhs = pair[1].strip()
+      # workaround for properties that contain '='
+      rhs = "=".join(pair[1:]).strip()
 
       part0 = lhs.split('.')[0]
 


Mime
View raw message