From 9d5a11198249c4be400ff5b77573d2ab87aa79b6 Mon Sep 17 00:00:00 2001
From: tsaavik <github@hellspark.com>
Date: Fri, 20 Dec 2013 10:18:46 -0800
Subject: [PATCH] Removed deprecated hadoop command for hdfs Made hdfs user
 configurable (FIXME: user plugin.conf)

---
 plugins/hadoop/hadoop-dfs-plugin | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/plugins/hadoop/hadoop-dfs-plugin b/plugins/hadoop/hadoop-dfs-plugin
index c99288e1..f89a165d 100755
--- a/plugins/hadoop/hadoop-dfs-plugin
+++ b/plugins/hadoop/hadoop-dfs-plugin
@@ -15,11 +15,12 @@
 use strict;
 use File::Basename qw(basename);
 
-my $type = &getType($0);
+my $hdfs_user = "hdfs";
 
 #
 # main
 #
+my $type = &getType($0);
 if ($ARGV[0]) {
 	if ($ARGV[0] eq "autoconf") {
 		print "yes\n";
@@ -95,7 +96,7 @@ sub getCapacity {
 }
 
 sub getStatistics {
-	open(DFSADMIN, "hadoop dfsadmin -report|") || die("Cannot open dfsadmin: $!");
+	open(DFSADMIN, "su $hdfs_user -c 'hdfs dfsadmin -report'|") || die("Cannot open dfsadmin: $!");
 	while(defined(my $line = <DFSADMIN>)) {
 		chomp($line);