From 3b6c81e7c0110333151bae525123fccc7934921d Mon Sep 17 00:00:00 2001 From: Himanshu Date: Wed, 7 Sep 2016 15:06:56 -0500 Subject: [PATCH] fix cleanup of hadoop ingestion intermediate path (#3385) --- .../main/java/io/druid/indexer/HadoopDruidIndexerConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/indexing-hadoop/src/main/java/io/druid/indexer/HadoopDruidIndexerConfig.java b/indexing-hadoop/src/main/java/io/druid/indexer/HadoopDruidIndexerConfig.java index eee296d27d6..f3dbc745058 100644 --- 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(":", ""),