You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by vb...@apache.org on 2015/09/14 15:30:16 UTC
ambari git commit: AMBARI-13089. Ambari seems to strip %Y %M %D,
etc partitioning options from Flume output paths.(vbrodetskyi)
Repository: ambari
Updated Branches:
refs/heads/branch-2.1 8630725ca -> 16713b896
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/16713b89
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/16713b89
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/16713b89
Branch: refs/heads/branch-2.1
Commit: 16713b8969cddfc74c5c412e120ae443b5283606
Parents: 8630725
Author: Vitaly Brodetskyi <vb...@hortonworks.com>
Authored: Mon Sep 14 16:29:38 2015 +0300
Committer: Vitaly Brodetskyi <vb...@hortonworks.com>
Committed: Mon Sep 14 16:29:38 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/16713b89/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 cff969f..b617313 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
@@ -239,7 +239,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]