diff --git a/indexing-hadoop/src/main/java/io/druid/indexer/rollup/DataRollupSpec.java b/indexing-hadoop/src/main/java/io/druid/indexer/rollup/DataRollupSpec.java index 86d04f9276f..e06932d0311 100644 --- a/indexing-hadoop/src/main/java/io/druid/indexer/rollup/DataRollupSpec.java +++ b/indexing-hadoop/src/main/java/io/druid/indexer/rollup/DataRollupSpec.java @@ -38,9 +38,6 @@ public class DataRollupSpec @JsonProperty public QueryGranularity rollupGranularity = QueryGranularity.NONE; - @JsonProperty - public int rowFlushBoundary = 500000; - public DataRollupSpec() {} public DataRollupSpec(List aggs, QueryGranularity rollupGranularity) diff --git a/indexing-service/src/main/java/io/druid/indexing/common/config/TaskConfig.java b/indexing-service/src/main/java/io/druid/indexing/common/config/TaskConfig.java index 1671fb84bd3..6d60d002484 100644 --- a/indexing-service/src/main/java/io/druid/indexing/common/config/TaskConfig.java +++ b/indexing-service/src/main/java/io/druid/indexing/common/config/TaskConfig.java @@ -41,9 +41,6 @@ public class TaskConfig @JsonProperty private final String hadoopWorkingPath; - @JsonProperty - private final int defaultRowFlushBoundary; - @JsonProperty private final List defaultHadoopCoordinates; @@ -59,7 +56,6 @@ public class TaskConfig this.baseDir = baseDir == null ? "/tmp" : baseDir; this.baseTaskDir = new File(defaultDir(baseTaskDir, "persistent/task")); this.hadoopWorkingPath = defaultDir(hadoopWorkingPath, "druid-indexing"); - this.defaultRowFlushBoundary = defaultRowFlushBoundary == null ? 500000 : defaultRowFlushBoundary; this.defaultHadoopCoordinates = defaultHadoopCoordinates == null ? DEFAULT_DEFAULT_HADOOP_COORDINATES : defaultHadoopCoordinates; @@ -83,12 +79,6 @@ public class TaskConfig return hadoopWorkingPath; } - @JsonProperty - public int getDefaultRowFlushBoundary() - { - return defaultRowFlushBoundary; - } - @JsonProperty public List getDefaultHadoopCoordinates() {