|
@@ -40,8 +40,9 @@ def setup_hadoop_env():
|
|
|
content=InlineTemplate(params.hadoop_env_sh_template)
|
|
|
)
|
|
|
if params.rpm_version is not None:
|
|
|
- Execute(format('ln -s /usr/hdp/{rpm_version}* {versioned_hdp_root}'),
|
|
|
- not_if=format('ls {versioned_hdp_root}')
|
|
|
+ Execute(format('ln -s /usr/hdp/{rpm_version}-* {versioned_hdp_root}'),
|
|
|
+ not_if=format('ls {versioned_hdp_root}'),
|
|
|
+ only_if=format('ls -d /usr/hdp/{rpm_version}-*')
|
|
|
)
|
|
|
|
|
|
def setup_config():
|