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

This commit is contained in:
flow 2014-09-27 22:26:52 +08:00
parent 7cfe86b7bc
commit 2dd62979bb
1 changed files with 1 additions and 1 deletions

View File

@ -448,7 +448,7 @@ public class IndexGeneratorJob implements Jobby
} else if (outputFS instanceof DistributedFileSystem) { } else if (outputFS instanceof DistributedFileSystem) {
loadSpec = ImmutableMap.<String, Object>of( loadSpec = ImmutableMap.<String, Object>of(
"type", "hdfs", "type", "hdfs",
"path", indexOutURI.getPath() "path", indexOutURI.toString()
); );
} else { } else {
throw new ISE("Unknown file system[%s]", outputFS.getClass()); throw new ISE("Unknown file system[%s]", outputFS.getClass());