Avoid prefixing already-prefixed ls output

Yelp · Nov 14, 2012 · 5cb2e46 · 5cb2e46
1 parent 282463f
commit 5cb2e46
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/mrjob/fs/hadoop.py b/mrjob/fs/hadoop.py
@@ -157,7 +157,7 @@ def ls(self, path_glob):
                     raise IOError("Could not locate path in string '%s'" % line)
 
             path = ' '.join(fields[path_index:])
-            yield hdfs_prefix + path
+            yield (hdfs_prefix if not path.startswith(hdfs_prefix) else '') + path
 
     def _cat_file(self, filename):
         # stream from HDFS