|
@@ -45,7 +45,19 @@ class HdfsClient(Script):
|
|
|
def configure(self, env):
|
|
|
import params
|
|
|
|
|
|
- pass
|
|
|
+ XmlConfig("core-site.xml",
|
|
|
+ conf_dir=params.hadoop_conf_dir,
|
|
|
+ configurations=params.config['configurations']['core-site'],
|
|
|
+ owner=params.hdfs_user,
|
|
|
+ group=params.user_group
|
|
|
+ )
|
|
|
+
|
|
|
+ XmlConfig("hdfs-site.xml",
|
|
|
+ conf_dir=params.hadoop_conf_dir,
|
|
|
+ configurations=params.config['configurations']['hdfs-site'],
|
|
|
+ owner=params.hdfs_user,
|
|
|
+ group=params.user_group
|
|
|
+ )
|
|
|
|
|
|
|
|
|
if __name__ == "__main__":
|