Skip to content

Commit fec1d58

Browse files
author
Donald Hunter
committed
Allow webhdfs user customization
1 parent f22607f commit fec1d58

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

api/src/main/resources/app.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -328,7 +328,7 @@ def main():
328328
package_registrar.HbasePackageRegistrar(
329329
config['environment']['hbase_thrift_server'],
330330
config['environment']['webhdfs_host'],
331-
'hdfs',
331+
config['environment']['webhdfs_user'],
332332
config['environment']['webhdfs_port'],
333333
config['config']['stage_root']),
334334
application_registrar.HbaseApplicationRegistrar(

api/src/main/resources/application_creator.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ def __init__(self, config, environment, service):
4444
self._name_regex = re.compile('')
4545
self._hdfs_client = HDFS(environment['webhdfs_host'],
4646
environment['webhdfs_port'],
47-
'hdfs')
47+
environment['webhdfs_user'])
4848

4949
def assert_application_properties(self, override_properties, default_properties):
5050
for component_type, component_properties in default_properties.iteritems():

0 commit comments

Comments
 (0)