fix hadoop bug

fjy · fjy · commit 98998b626ac0 · 2015-01-20T16:26:41.000-08:00
diff --git a/indexing-hadoop/src/main/java/io/druid/indexer/HadoopDruidIndexerConfig.java b/indexing-hadoop/src/main/java/io/druid/indexer/HadoopDruidIndexerConfig.java
@@ -115,7 +115,7 @@ public static HadoopDruidIndexerConfig fromSpec(HadoopIngestionSpec spec)
   public static HadoopDruidIndexerConfig fromMap(Map<String, Object> argSpec)
   {
     //backwards compatibility
-    if (argSpec.containsKey("schema")) {
+    if (argSpec.containsKey("schema") || argSpec.containsKey("spec")) {
       return HadoopDruidIndexerConfig.jsonMapper.convertValue(argSpec, HadoopDruidIndexerConfig.class);
     } else {
       return new HadoopDruidIndexerConfig(

Original file line number	Diff line number	Diff line change
`@@ -115,7 +115,7 @@ public static HadoopDruidIndexerConfig fromSpec(HadoopIngestionSpec spec)`
`115`	`115`	`public static HadoopDruidIndexerConfig fromMap(Map<String, Object> argSpec)`
`116`	`116`	`{`
`117`	`117`	`//backwards compatibility`
`118`		`- if (argSpec.containsKey("schema")) {`
	`118`	`+ if (argSpec.containsKey("schema") \|\| argSpec.containsKey("spec")) {`
`119`	`119`	`return HadoopDruidIndexerConfig.jsonMapper.convertValue(argSpec, HadoopDruidIndexerConfig.class);`
`120`	`120`	`} else {`
`121`	`121`	`return new HadoopDruidIndexerConfig(`