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 1ff6e5a4482..e6402221e45 100644 --- a/indexing-hadoop/src/main/java/io/druid/indexer/HadoopDruidIndexerConfig.java +++ b/indexing-hadoop/src/main/java/io/druid/indexer/HadoopDruidIndexerConfig.java @@ -170,7 +170,6 @@ public class HadoopDruidIndexerConfig private volatile HadoopIngestionSpec schema; private volatile PathSpec pathSpec; - private volatile ColumnConfig columnConfig; private volatile Map shardSpecLookups = Maps.newHashMap(); private volatile Map hadoopShardSpecLookup = Maps.newHashMap(); @@ -179,7 +178,6 @@ public class HadoopDruidIndexerConfig final @JsonProperty("schema") HadoopIngestionSpec schema ) { - this.columnConfig = columnConfig; this.schema = schema; this.pathSpec = jsonMapper.convertValue(schema.getIOConfig().getPathSpec(), PathSpec.class); for (Map.Entry> entry : schema.getTuningConfig().getShardSpecs().entrySet()) { @@ -213,11 +211,6 @@ public class HadoopDruidIndexerConfig return schema; } - public ColumnConfig getColumnConfig() - { - return columnConfig; - } - public String getDataSource() { return schema.getDataSchema().getDataSource();