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.of( "type", "hdfs", - "path", indexOutURI.getPath() + "path", indexOutURI.toString() ); } else { throw new ISE("Unknown file system[%s]", outputFS.getClass());