From 2dd62979bbcb4172fc801c918a750e6fcc4ec648 Mon Sep 17 00:00:00 2001
From: flow <flowbehappy@gmail.com>
Date: Sat, 27 Sep 2014 22:26:52 +0800
Subject: [PATCH] Fixed the issue of batch ingestion with indexing service to
 hdfs end up with the path of metadata in mysql missing "hdfs://host" prefix.
 The detail describe can be found here:
 https://groups.google.com/forum/#!topic/druid-development/ofvSxiPpCxI

---
 .../src/main/java/io/druid/indexer/IndexGeneratorJob.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/indexing-hadoop/src/main/java/io/druid/indexer/IndexGeneratorJob.java b/indexing-hadoop/src/main/java/io/druid/indexer/IndexGeneratorJob.java
index 6dd97b920ba..e562f7f45d6 100644
--- a/indexing-hadoop/src/main/java/io/druid/indexer/IndexGeneratorJob.java
+++ b/indexing-hadoop/src/main/java/io/druid/indexer/IndexGeneratorJob.java
@@ -448,7 +448,7 @@ public class IndexGeneratorJob implements Jobby
       } else if (outputFS instanceof DistributedFileSystem) {
         loadSpec = ImmutableMap.<String, Object>of(
             "type", "hdfs",
-            "path", indexOutURI.getPath()
+            "path", indexOutURI.toString()
         );
       } else {
         throw new ISE("Unknown file system[%s]", outputFS.getClass());