[
https://issues.apache.org/jira/browse/AMBARI-14536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yaolei updated AMBARI-14536:
----------------------------
Description:
In some cases,we need to copy matching wildcard file to hdfs.
eg.
HdfsResource = functools.partial(HdfsResource,
user=hdfs_user,
security_enabled =
security_enabled,
keytab = hdfs_user_keytab,
kinit_path_local =
kinit_path_local,
hadoop_bin_dir =
hadoop_bin_dir,
hadoop_conf_dir =
hadoop_conf_dir,
principal_name =
hdfs_principal_name,
hdfs_site = hdfs_site,
default_fs = default_fs)
params.HdfsResource(hdfs_path,
type="file",
action="create_on_execute",
source="/usr/lib/spark*.jar",
group=params.user_group,
owner=params.pdm_user,
mode=0755
)
params.HdfsResource(None, action="execute")
was:
In some cases,we need to copy matching wildcard file to hdfs.
eg.
HdfsResource = functools.partial(
HdfsResource,
user=hdfs_user,
security_enabled = security_enabled,
keytab = hdfs_user_keytab,
kinit_path_local = kinit_path_local,
hadoop_bin_dir = hadoop_bin_dir,
hadoop_conf_dir = hadoop_conf_dir,
principal_name = hdfs_principal_name,
hdfs_site = hdfs_site,
default_fs = default_fs
)
params.HdfsResource(hdfs_path,
type="file",
action="create_on_execute",
source="/usr/lib/spark*.jar",
group=params.user_group,
owner=params.pdm_user,
mode=0755
)
params.HdfsResource(None, action="execute")
> Enhance the function of HdfsResource to copy matching wildcard file to hdfs
> ---------------------------------------------------------------------------
>
> Key: AMBARI-14536
> URL: https://issues.apache.org/jira/browse/AMBARI-14536
> Project: Ambari
> Issue Type: Improvement
> Affects Versions: 2.1.1
> Reporter: yaolei
> Priority: Minor
> Fix For: 2.3.0
>
>
> In some cases,we need to copy matching wildcard file to hdfs.
> eg.
> HdfsResource = functools.partial(HdfsResource,
> user=hdfs_user,
> security_enabled =
> security_enabled,
> keytab = hdfs_user_keytab,
> kinit_path_local =
> kinit_path_local,
> hadoop_bin_dir =
> hadoop_bin_dir,
> hadoop_conf_dir =
> hadoop_conf_dir,
> principal_name =
> hdfs_principal_name,
> hdfs_site = hdfs_site,
> default_fs = default_fs)
> params.HdfsResource(hdfs_path,
> type="file",
> action="create_on_execute",
> source="/usr/lib/spark*.jar",
> group=params.user_group,
> owner=params.pdm_user,
> mode=0755
> )
> params.HdfsResource(None, action="execute")
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)