fix cleanup of hadoop ingestion intermediate path (#3385)

2016-09-07 15:06:56 -05:00 · 2016-09-07 15:06:56 -05:00 · 3b6c81e7c0
parent 1e3f94237e
commit 3b6c81e7c0
1 changed files with 1 additions and 1 deletions
--- a/indexing-hadoop/src/main/java/io/druid/indexer/HadoopDruidIndexerConfig.java
+++ b/indexing-hadoop/src/main/java/io/druid/indexer/HadoopDruidIndexerConfig.java
@ -487,7 +487,7 @@ public class HadoopDruidIndexerConfig
  {
    return new Path(
        String.format(
-            "%s/%s/%s/%s",
+            "%s/%s/%s_%s",
            getWorkingPath(),
            schema.getDataSchema().getDataSource(),
            schema.getTuningConfig().getVersion().replace(":", ""),