From 1e941204c49be8937d48d4f78fd53c1130659a9b Mon Sep 17 00:00:00 2001 From: yuanyi Date: Wed, 9 Jun 2021 14:24:56 +0800 Subject: [PATCH 1/5] delete_buildV9Directly_in_kafka_and_kinesis_indexing_service --- .../druid/indexing/kafka/KafkaIndexTaskTuningConfig.java | 3 --- .../kafka/supervisor/KafkaSupervisorTuningConfig.java | 5 ----- .../org/apache/druid/indexing/kafka/KafkaIndexTaskTest.java | 1 - .../indexing/kafka/KafkaIndexTaskTuningConfigTest.java | 3 --- .../indexing/kafka/supervisor/KafkaSupervisorTest.java | 6 ------ .../kafka/test/TestModifiedKafkaIndexTaskTuningConfig.java | 3 --- .../indexing/kinesis/KinesisIndexTaskTuningConfig.java | 2 -- .../kinesis/supervisor/KinesisSupervisorTuningConfig.java | 4 ---- .../druid/indexing/kinesis/KinesisIndexTaskSerdeTest.java | 1 - .../apache/druid/indexing/kinesis/KinesisIndexTaskTest.java | 1 - .../indexing/kinesis/KinesisIndexTaskTuningConfigTest.java | 5 ----- .../indexing/kinesis/supervisor/KinesisSupervisorTest.java | 3 --- .../supervisor/KinesisSupervisorTuningConfigTest.java | 1 - .../test/TestModifiedKinesisIndexTaskTuningConfig.java | 3 --- 14 files changed, 41 deletions(-) diff --git a/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfig.java b/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfig.java index 2a7b077202f7..1935973c9b83 100644 --- a/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfig.java +++ b/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfig.java @@ -45,8 +45,6 @@ public KafkaIndexTaskTuningConfig( @JsonProperty("maxPendingPersists") @Nullable Integer maxPendingPersists, @JsonProperty("indexSpec") @Nullable IndexSpec indexSpec, @JsonProperty("indexSpecForIntermediatePersists") @Nullable IndexSpec indexSpecForIntermediatePersists, - // This parameter is left for compatibility when reading existing configs, to be removed in Druid 0.12. - @JsonProperty("buildV9Directly") @Nullable Boolean buildV9Directly, @Deprecated @JsonProperty("reportParseExceptions") @Nullable Boolean reportParseExceptions, @JsonProperty("handoffConditionTimeout") @Nullable Long handoffConditionTimeout, @JsonProperty("resetOffsetAutomatically") @Nullable Boolean resetOffsetAutomatically, @@ -97,7 +95,6 @@ public KafkaIndexTaskTuningConfig withBasePersistDirectory(File dir) getMaxPendingPersists(), getIndexSpec(), getIndexSpecForIntermediatePersists(), - true, isReportParseExceptions(), getHandoffConditionTimeout(), isResetOffsetAutomatically(), diff --git a/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTuningConfig.java b/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTuningConfig.java index 04cc74fa416d..4fc5489a8d4c 100644 --- a/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTuningConfig.java +++ b/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTuningConfig.java @@ -68,7 +68,6 @@ public static KafkaSupervisorTuningConfig defaultConfig() null, null, null, - null, null ); } @@ -85,8 +84,6 @@ public KafkaSupervisorTuningConfig( @JsonProperty("maxPendingPersists") Integer maxPendingPersists, @JsonProperty("indexSpec") IndexSpec indexSpec, @JsonProperty("indexSpecForIntermediatePersists") @Nullable IndexSpec indexSpecForIntermediatePersists, - // This parameter is left for compatibility when reading existing configs, to be removed in Druid 0.12. - @JsonProperty("buildV9Directly") Boolean buildV9Directly, @JsonProperty("reportParseExceptions") Boolean reportParseExceptions, @JsonProperty("handoffConditionTimeout") Long handoffConditionTimeout, @JsonProperty("resetOffsetAutomatically") Boolean resetOffsetAutomatically, @@ -115,7 +112,6 @@ public KafkaSupervisorTuningConfig( maxPendingPersists, indexSpec, indexSpecForIntermediatePersists, - true, reportParseExceptions, handoffConditionTimeout, resetOffsetAutomatically, @@ -237,7 +233,6 @@ public KafkaIndexTaskTuningConfig convertToTaskTuningConfig() getMaxPendingPersists(), getIndexSpec(), getIndexSpecForIntermediatePersists(), - true, isReportParseExceptions(), getHandoffConditionTimeout(), isResetOffsetAutomatically(), diff --git a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTest.java b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTest.java index 34ef75cc87a3..9f15091bef30 100644 --- a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTest.java +++ b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTest.java @@ -2685,7 +2685,6 @@ private KafkaIndexTask createTask( null, null, null, - true, reportParseExceptions, handoffConditionTimeout, resetOffsetAutomatically, diff --git a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfigTest.java b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfigTest.java index e27d7d0c07d4..4ec32acd4f3b 100644 --- a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfigTest.java +++ b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfigTest.java @@ -132,7 +132,6 @@ public void testConvert() new IndexSpec(), new IndexSpec(), true, - true, 5L, null, null, @@ -178,7 +177,6 @@ public void testSerdeWithModifiedTuningConfigAddedField() throws IOException new IndexSpec(), new IndexSpec(), true, - true, 5L, null, null, @@ -229,7 +227,6 @@ public void testSerdeWithModifiedTuningConfigRemovedField() throws IOException new IndexSpec(), new IndexSpec(), true, - true, 5L, null, null, diff --git a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java index ac6b6e50590f..c248a110a853 100644 --- a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java +++ b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java @@ -311,7 +311,6 @@ public KafkaIndexTaskClient build( null, null, null, - true, false, null, false, @@ -468,7 +467,6 @@ public void testCreateBaseTaskContexts() throws JsonProcessingException null, null, null, - null, null ), null @@ -3280,7 +3278,6 @@ public void testIsTaskCurrent() null, null, null, - true, false, null, false, @@ -3321,7 +3318,6 @@ public void testIsTaskCurrent() null, null, null, - true, false, null, null, @@ -3619,7 +3615,6 @@ public KafkaIndexTaskClient build( null, null, null, - true, false, null, resetOffsetAutomatically, @@ -3732,7 +3727,6 @@ public KafkaIndexTaskClient build( null, null, null, - true, false, null, false, diff --git a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/test/TestModifiedKafkaIndexTaskTuningConfig.java b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/test/TestModifiedKafkaIndexTaskTuningConfig.java index 2c1a684d6587..642141c3c4fa 100644 --- a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/test/TestModifiedKafkaIndexTaskTuningConfig.java +++ b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/test/TestModifiedKafkaIndexTaskTuningConfig.java @@ -49,8 +49,6 @@ public TestModifiedKafkaIndexTaskTuningConfig( @JsonProperty("maxPendingPersists") @Nullable Integer maxPendingPersists, @JsonProperty("indexSpec") @Nullable IndexSpec indexSpec, @JsonProperty("indexSpecForIntermediatePersists") @Nullable IndexSpec indexSpecForIntermediatePersists, - // This parameter is left for compatibility when reading existing configs, to be removed in Druid 0.12. - @JsonProperty("buildV9Directly") @Nullable Boolean buildV9Directly, @Deprecated @JsonProperty("reportParseExceptions") @Nullable Boolean reportParseExceptions, @JsonProperty("handoffConditionTimeout") @Nullable Long handoffConditionTimeout, @JsonProperty("resetOffsetAutomatically") @Nullable Boolean resetOffsetAutomatically, @@ -74,7 +72,6 @@ public TestModifiedKafkaIndexTaskTuningConfig( maxPendingPersists, indexSpec, indexSpecForIntermediatePersists, - true, reportParseExceptions, handoffConditionTimeout, resetOffsetAutomatically, diff --git a/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfig.java b/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfig.java index 2bbfffe5bc7e..57124060c0a8 100644 --- a/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfig.java +++ b/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfig.java @@ -62,7 +62,6 @@ public KinesisIndexTaskTuningConfig( @JsonProperty("maxPendingPersists") Integer maxPendingPersists, @JsonProperty("indexSpec") IndexSpec indexSpec, @JsonProperty("indexSpecForIntermediatePersists") @Nullable IndexSpec indexSpecForIntermediatePersists, - @JsonProperty("buildV9Directly") Boolean buildV9Directly, @JsonProperty("reportParseExceptions") Boolean reportParseExceptions, @JsonProperty("handoffConditionTimeout") Long handoffConditionTimeout, @JsonProperty("resetOffsetAutomatically") Boolean resetOffsetAutomatically, @@ -170,7 +169,6 @@ public KinesisIndexTaskTuningConfig withBasePersistDirectory(File dir) getMaxPendingPersists(), getIndexSpec(), getIndexSpecForIntermediatePersists(), - true, isReportParseExceptions(), getHandoffConditionTimeout(), isResetOffsetAutomatically(), diff --git a/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfig.java b/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfig.java index 56c94568b746..6fba06d611b5 100644 --- a/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfig.java +++ b/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfig.java @@ -77,7 +77,6 @@ public static KinesisSupervisorTuningConfig defaultConfig() null, null, null, - null, null ); } @@ -94,7 +93,6 @@ public KinesisSupervisorTuningConfig( @JsonProperty("maxPendingPersists") Integer maxPendingPersists, @JsonProperty("indexSpec") IndexSpec indexSpec, @JsonProperty("indexSpecForIntermediatePersists") @Nullable IndexSpec indexSpecForIntermediatePersists, - @JsonProperty("buildV9Directly") Boolean buildV9Directly, @JsonProperty("reportParseExceptions") Boolean reportParseExceptions, @JsonProperty("handoffConditionTimeout") Long handoffConditionTimeout, @JsonProperty("resetOffsetAutomatically") Boolean resetOffsetAutomatically, @@ -131,7 +129,6 @@ public KinesisSupervisorTuningConfig( maxPendingPersists, indexSpec, indexSpecForIntermediatePersists, - buildV9Directly, reportParseExceptions, handoffConditionTimeout, resetOffsetAutomatically, @@ -267,7 +264,6 @@ public KinesisIndexTaskTuningConfig convertToTaskTuningConfig() getMaxPendingPersists(), getIndexSpec(), getIndexSpecForIntermediatePersists(), - true, isReportParseExceptions(), getHandoffConditionTimeout(), isResetOffsetAutomatically(), diff --git a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskSerdeTest.java b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskSerdeTest.java index c279a1814981..f6b3582f96b1 100644 --- a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskSerdeTest.java +++ b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskSerdeTest.java @@ -73,7 +73,6 @@ public class KinesisIndexTaskSerdeTest null, null, null, - null, null ); private static final KinesisIndexTaskIOConfig IO_CONFIG = new KinesisIndexTaskIOConfig( diff --git a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTest.java b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTest.java index 19d2445f7ee2..ebc446418cfa 100644 --- a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTest.java +++ b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTest.java @@ -2766,7 +2766,6 @@ private KinesisIndexTask createTask( null, null, null, - true, reportParseExceptions, handoffConditionTimeout, resetOffsetAutomatically, diff --git a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfigTest.java b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfigTest.java index 360067195de3..b74aaedf1bb3 100644 --- a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfigTest.java +++ b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfigTest.java @@ -96,7 +96,6 @@ public void testSerdeWithNonDefaults() throws Exception + " \"maxRowsPerSegment\": 100,\n" + " \"intermediatePersistPeriod\": \"PT1H\",\n" + " \"maxPendingPersists\": 100,\n" - + " \"buildV9Directly\": true,\n" + " \"reportParseExceptions\": true,\n" + " \"handoffConditionTimeout\": 100,\n" + " \"recordBufferSize\": 1000,\n" @@ -153,7 +152,6 @@ public void testSerdeWithModifiedTuningConfigAddedField() throws IOException new IndexSpec(), new IndexSpec(), true, - true, 5L, true, false, @@ -215,7 +213,6 @@ public void testSerdeWithModifiedTuningConfigRemovedField() throws IOException new IndexSpec(), new IndexSpec(), true, - true, 5L, true, false, @@ -270,7 +267,6 @@ public void testResetOffsetAndSkipSequenceNotBothTrue() throws Exception + " \"maxRowsPerSegment\": 100,\n" + " \"intermediatePersistPeriod\": \"PT1H\",\n" + " \"maxPendingPersists\": 100,\n" - + " \"buildV9Directly\": true,\n" + " \"reportParseExceptions\": true,\n" + " \"handoffConditionTimeout\": 100,\n" + " \"recordBufferSize\": 1000,\n" @@ -305,7 +301,6 @@ public void testConvert() new IndexSpec(), new IndexSpec(), true, - true, 5L, true, false, diff --git a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTest.java b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTest.java index 5d1d0f6a0099..52ef70a97606 100644 --- a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTest.java +++ b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTest.java @@ -181,7 +181,6 @@ public void setupTest() null, null, null, - true, false, null, null, @@ -3772,7 +3771,6 @@ public void testIsTaskCurrent() null, null, null, - true, false, null, null, @@ -4827,7 +4825,6 @@ public KinesisIndexTaskClient build( null, null, null, - true, false, null, resetOffsetAutomatically, diff --git a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfigTest.java b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfigTest.java index ff3edc46e429..6af36a7a1121 100644 --- a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfigTest.java +++ b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfigTest.java @@ -86,7 +86,6 @@ public void testSerdeWithNonDefaults() throws Exception + " \"maxRowsPerSegment\": 100,\n" + " \"intermediatePersistPeriod\": \"PT1H\",\n" + " \"maxPendingPersists\": 100,\n" - + " \"buildV9Directly\": false,\n" + " \"reportParseExceptions\": true,\n" + " \"handoffConditionTimeout\": 100,\n" + " \"workerThreads\": 12,\n" diff --git a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/test/TestModifiedKinesisIndexTaskTuningConfig.java b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/test/TestModifiedKinesisIndexTaskTuningConfig.java index 9278c1037170..ed3a20cf20f9 100644 --- a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/test/TestModifiedKinesisIndexTaskTuningConfig.java +++ b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/test/TestModifiedKinesisIndexTaskTuningConfig.java @@ -49,7 +49,6 @@ public TestModifiedKinesisIndexTaskTuningConfig( @JsonProperty("maxPendingPersists") Integer maxPendingPersists, @JsonProperty("indexSpec") IndexSpec indexSpec, @JsonProperty("indexSpecForIntermediatePersists") @Nullable IndexSpec indexSpecForIntermediatePersists, - @JsonProperty("buildV9Directly") Boolean buildV9Directly, @JsonProperty("reportParseExceptions") Boolean reportParseExceptions, @JsonProperty("handoffConditionTimeout") Long handoffConditionTimeout, @JsonProperty("resetOffsetAutomatically") Boolean resetOffsetAutomatically, @@ -80,7 +79,6 @@ public TestModifiedKinesisIndexTaskTuningConfig( maxPendingPersists, indexSpec, indexSpecForIntermediatePersists, - buildV9Directly, reportParseExceptions, handoffConditionTimeout, resetOffsetAutomatically, @@ -114,7 +112,6 @@ public TestModifiedKinesisIndexTaskTuningConfig(KinesisIndexTaskTuningConfig bas base.getMaxPendingPersists(), base.getIndexSpec(), base.getIndexSpecForIntermediatePersists(), - base.getBuildV9Directly(), base.isReportParseExceptions(), base.getHandoffConditionTimeout(), base.isResetOffsetAutomatically(), From 348a70531d61a8ec4d3debcbf89da5935a08862f Mon Sep 17 00:00:00 2001 From: yuanyi Date: Thu, 10 Jun 2021 19:14:38 +0800 Subject: [PATCH 2/5] delete --- .../kafka/KafkaIndexTaskTuningConfigTest.java | 2 -- .../kinesis/KinesisIndexTaskTuningConfigTest.java | 5 ----- .../KinesisSupervisorTuningConfigTest.java | 2 -- .../SeekableStreamIndexTaskTuningConfig.java | 12 ------------ 4 files changed, 21 deletions(-) diff --git a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfigTest.java b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfigTest.java index 4ec32acd4f3b..6674c36f17dd 100644 --- a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfigTest.java +++ b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaIndexTaskTuningConfigTest.java @@ -200,7 +200,6 @@ public void testSerdeWithModifiedTuningConfigAddedField() throws IOException Assert.assertEquals(base.getBasePersistDirectory(), deserialized.getBasePersistDirectory()); Assert.assertEquals(base.getMaxPendingPersists(), deserialized.getMaxPendingPersists()); Assert.assertEquals(base.getIndexSpec(), deserialized.getIndexSpec()); - Assert.assertEquals(base.getBuildV9Directly(), deserialized.getBuildV9Directly()); Assert.assertEquals(base.isReportParseExceptions(), deserialized.isReportParseExceptions()); Assert.assertEquals(base.getHandoffConditionTimeout(), deserialized.getHandoffConditionTimeout()); Assert.assertEquals(base.isResetOffsetAutomatically(), deserialized.isResetOffsetAutomatically()); @@ -250,7 +249,6 @@ public void testSerdeWithModifiedTuningConfigRemovedField() throws IOException Assert.assertEquals(base.getBasePersistDirectory(), deserialized.getBasePersistDirectory()); Assert.assertEquals(base.getMaxPendingPersists(), deserialized.getMaxPendingPersists()); Assert.assertEquals(base.getIndexSpec(), deserialized.getIndexSpec()); - Assert.assertEquals(base.getBuildV9Directly(), deserialized.getBuildV9Directly()); Assert.assertEquals(base.isReportParseExceptions(), deserialized.isReportParseExceptions()); Assert.assertEquals(base.getHandoffConditionTimeout(), deserialized.getHandoffConditionTimeout()); Assert.assertEquals(base.isResetOffsetAutomatically(), deserialized.isResetOffsetAutomatically()); diff --git a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfigTest.java b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfigTest.java index b74aaedf1bb3..3bba03e9136c 100644 --- a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfigTest.java +++ b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfigTest.java @@ -74,7 +74,6 @@ public void testSerdeWithDefaults() throws Exception Assert.assertEquals(new Period("PT10M"), config.getIntermediatePersistPeriod()); Assert.assertEquals(0, config.getMaxPendingPersists()); Assert.assertEquals(new IndexSpec(), config.getIndexSpec()); - Assert.assertTrue(config.getBuildV9Directly()); Assert.assertFalse(config.isReportParseExceptions()); Assert.assertEquals(0, config.getHandoffConditionTimeout()); Assert.assertEquals(10000, config.getRecordBufferSize()); @@ -124,7 +123,6 @@ public void testSerdeWithNonDefaults() throws Exception Assert.assertEquals(100, config.getMaxRowsPerSegment().intValue()); Assert.assertEquals(new Period("PT1H"), config.getIntermediatePersistPeriod()); Assert.assertEquals(100, config.getMaxPendingPersists()); - Assert.assertTrue(config.getBuildV9Directly()); Assert.assertTrue(config.isReportParseExceptions()); Assert.assertEquals(100, config.getHandoffConditionTimeout()); Assert.assertEquals(1000, config.getRecordBufferSize()); @@ -182,7 +180,6 @@ public void testSerdeWithModifiedTuningConfigAddedField() throws IOException Assert.assertEquals(base.getBasePersistDirectory(), deserialized.getBasePersistDirectory()); Assert.assertEquals(base.getMaxPendingPersists(), deserialized.getMaxPendingPersists()); Assert.assertEquals(base.getIndexSpec(), deserialized.getIndexSpec()); - Assert.assertEquals(base.getBuildV9Directly(), deserialized.getBuildV9Directly()); Assert.assertEquals(base.isReportParseExceptions(), deserialized.isReportParseExceptions()); Assert.assertEquals(base.getHandoffConditionTimeout(), deserialized.getHandoffConditionTimeout()); Assert.assertEquals(base.isResetOffsetAutomatically(), deserialized.isResetOffsetAutomatically()); @@ -242,7 +239,6 @@ public void testSerdeWithModifiedTuningConfigRemovedField() throws IOException Assert.assertEquals(base.getBasePersistDirectory(), deserialized.getBasePersistDirectory()); Assert.assertEquals(base.getMaxPendingPersists(), deserialized.getMaxPendingPersists()); Assert.assertEquals(base.getIndexSpec(), deserialized.getIndexSpec()); - Assert.assertEquals(base.getBuildV9Directly(), deserialized.getBuildV9Directly()); Assert.assertEquals(base.isReportParseExceptions(), deserialized.isReportParseExceptions()); Assert.assertEquals(base.getHandoffConditionTimeout(), deserialized.getHandoffConditionTimeout()); Assert.assertEquals(base.isResetOffsetAutomatically(), deserialized.isResetOffsetAutomatically()); @@ -334,7 +330,6 @@ public void testConvert() Assert.assertEquals(new File("/tmp/xxx"), copy.getBasePersistDirectory()); Assert.assertEquals(4, copy.getMaxPendingPersists()); Assert.assertEquals(new IndexSpec(), copy.getIndexSpec()); - Assert.assertTrue(copy.getBuildV9Directly()); Assert.assertTrue(copy.isReportParseExceptions()); Assert.assertEquals(5L, copy.getHandoffConditionTimeout()); Assert.assertEquals(1000, copy.getRecordBufferSize()); diff --git a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfigTest.java b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfigTest.java index 6af36a7a1121..c043cbdea5e3 100644 --- a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfigTest.java +++ b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTuningConfigTest.java @@ -65,7 +65,6 @@ public void testSerdeWithDefaults() throws Exception Assert.assertEquals(new Period("PT10M"), config.getIntermediatePersistPeriod()); Assert.assertEquals(0, config.getMaxPendingPersists()); Assert.assertEquals(new IndexSpec(), config.getIndexSpec()); - Assert.assertEquals(true, config.getBuildV9Directly()); Assert.assertEquals(false, config.isReportParseExceptions()); Assert.assertEquals(0, config.getHandoffConditionTimeout()); Assert.assertNull(config.getWorkerThreads()); @@ -113,7 +112,6 @@ public void testSerdeWithNonDefaults() throws Exception Assert.assertEquals(100, config.getMaxRowsPerSegment().intValue()); Assert.assertEquals(new Period("PT1H"), config.getIntermediatePersistPeriod()); Assert.assertEquals(100, config.getMaxPendingPersists()); - Assert.assertEquals(true, config.getBuildV9Directly()); Assert.assertEquals(true, config.isReportParseExceptions()); Assert.assertEquals(100, config.getHandoffConditionTimeout()); Assert.assertEquals(12, (int) config.getWorkerThreads()); diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskTuningConfig.java b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskTuningConfig.java index bad2f79c12c9..2d3445f3a8d9 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskTuningConfig.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskTuningConfig.java @@ -73,8 +73,6 @@ public SeekableStreamIndexTaskTuningConfig( @Nullable Integer maxPendingPersists, @Nullable IndexSpec indexSpec, @Nullable IndexSpec indexSpecForIntermediatePersists, - // This parameter is left for compatibility when reading existing configs, to be removed in Druid 0.12. - @Deprecated @JsonProperty("buildV9Directly") @Nullable Boolean buildV9Directly, @Deprecated @Nullable Boolean reportParseExceptions, @Nullable Long handoffConditionTimeout, @Nullable Boolean resetOffsetAutomatically, @@ -223,16 +221,6 @@ public IndexSpec getIndexSpecForIntermediatePersists() return indexSpecForIntermediatePersists; } - /** - * Always returns true, doesn't affect the version being built. - */ - @Deprecated - @JsonProperty - public boolean getBuildV9Directly() - { - return true; - } - @Override @JsonProperty public boolean isReportParseExceptions() From 5e59a18cb21b8b053b37aecc2bcf6ada8c637c89 Mon Sep 17 00:00:00 2001 From: yuanyi Date: Fri, 11 Jun 2021 15:07:10 +0800 Subject: [PATCH 3/5] delete them from server --- .../druid/indexing/common/task/IndexTask.java | 9 --------- .../segment/indexing/RealtimeTuningConfig.java | 15 --------------- .../appenderator/AppenderatorPlumberTest.java | 1 - .../realtime/appenderator/AppenderatorTester.java | 1 - .../DefaultOfflineAppenderatorFactoryTest.java | 1 - .../plumber/RealtimePlumberSchoolTest.java | 1 - .../druid/segment/realtime/plumber/SinkTest.java | 2 -- 7 files changed, 30 deletions(-) diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/common/task/IndexTask.java b/indexing-service/src/main/java/org/apache/druid/indexing/common/task/IndexTask.java index e677995f787f..a7985223483a 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/common/task/IndexTask.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/common/task/IndexTask.java @@ -1481,15 +1481,6 @@ public int getMaxPendingPersists() return maxPendingPersists; } - /** - * Always returns true, doesn't affect the version being built. - */ - @Deprecated - @JsonProperty - public boolean isBuildV9Directly() - { - return true; - } @JsonProperty public boolean isForceGuaranteedRollup() diff --git a/server/src/main/java/org/apache/druid/segment/indexing/RealtimeTuningConfig.java b/server/src/main/java/org/apache/druid/segment/indexing/RealtimeTuningConfig.java index e7b4525793bd..6901fafd79e7 100644 --- a/server/src/main/java/org/apache/druid/segment/indexing/RealtimeTuningConfig.java +++ b/server/src/main/java/org/apache/druid/segment/indexing/RealtimeTuningConfig.java @@ -78,7 +78,6 @@ public static RealtimeTuningConfig makeDefaultTuningConfig(final @Nullable File DEFAULT_SHARD_SPEC, DEFAULT_INDEX_SPEC, DEFAULT_INDEX_SPEC, - true, 0, 0, DEFAULT_REPORT_PARSE_EXCEPTIONS, @@ -127,8 +126,6 @@ public RealtimeTuningConfig( @JsonProperty("shardSpec") ShardSpec shardSpec, @JsonProperty("indexSpec") IndexSpec indexSpec, @JsonProperty("indexSpecForIntermediatePersists") @Nullable IndexSpec indexSpecForIntermediatePersists, - // This parameter is left for compatibility when reading existing configs, to be removed in Druid 0.12. - @JsonProperty("buildV9Directly") Boolean buildV9Directly, @JsonProperty("persistThreadPriority") int persistThreadPriority, @JsonProperty("mergeThreadPriority") int mergeThreadPriority, @JsonProperty("reportParseExceptions") Boolean reportParseExceptions, @@ -268,16 +265,6 @@ public IndexSpec getIndexSpecForIntermediatePersists() return indexSpecForIntermediatePersists; } - /** - * Always returns true, doesn't affect the version being built. - */ - @Deprecated - @JsonProperty - public Boolean getBuildV9Directly() - { - return true; - } - @JsonProperty public int getPersistThreadPriority() { @@ -340,7 +327,6 @@ public RealtimeTuningConfig withVersioningPolicy(VersioningPolicy policy) shardSpec, indexSpec, indexSpecForIntermediatePersists, - true, persistThreadPriority, mergeThreadPriority, reportParseExceptions, @@ -368,7 +354,6 @@ public RealtimeTuningConfig withBasePersistDirectory(File dir) shardSpec, indexSpec, indexSpecForIntermediatePersists, - true, persistThreadPriority, mergeThreadPriority, reportParseExceptions, diff --git a/server/src/test/java/org/apache/druid/segment/realtime/appenderator/AppenderatorPlumberTest.java b/server/src/test/java/org/apache/druid/segment/realtime/appenderator/AppenderatorPlumberTest.java index 78210d3bc191..c07fbd07cf7f 100644 --- a/server/src/test/java/org/apache/druid/segment/realtime/appenderator/AppenderatorPlumberTest.java +++ b/server/src/test/java/org/apache/druid/segment/realtime/appenderator/AppenderatorPlumberTest.java @@ -75,7 +75,6 @@ public AppenderatorPlumberTest() throws Exception null, null, null, - true, 0, 0, false, diff --git a/server/src/test/java/org/apache/druid/segment/realtime/appenderator/AppenderatorTester.java b/server/src/test/java/org/apache/druid/segment/realtime/appenderator/AppenderatorTester.java index 1231b7721693..600662e1f98c 100644 --- a/server/src/test/java/org/apache/druid/segment/realtime/appenderator/AppenderatorTester.java +++ b/server/src/test/java/org/apache/druid/segment/realtime/appenderator/AppenderatorTester.java @@ -187,7 +187,6 @@ public AppenderatorTester( null, null, null, - null, 0, 0, null, diff --git a/server/src/test/java/org/apache/druid/segment/realtime/appenderator/DefaultOfflineAppenderatorFactoryTest.java b/server/src/test/java/org/apache/druid/segment/realtime/appenderator/DefaultOfflineAppenderatorFactoryTest.java index 491f4b26d702..36c9c5bce223 100644 --- a/server/src/test/java/org/apache/druid/segment/realtime/appenderator/DefaultOfflineAppenderatorFactoryTest.java +++ b/server/src/test/java/org/apache/druid/segment/realtime/appenderator/DefaultOfflineAppenderatorFactoryTest.java @@ -147,7 +147,6 @@ public int columnCacheSizeBytes() null, null, null, - null, 0, 0, null, diff --git a/server/src/test/java/org/apache/druid/segment/realtime/plumber/RealtimePlumberSchoolTest.java b/server/src/test/java/org/apache/druid/segment/realtime/plumber/RealtimePlumberSchoolTest.java index f2944224a1e7..0039690779ff 100644 --- a/server/src/test/java/org/apache/druid/segment/realtime/plumber/RealtimePlumberSchoolTest.java +++ b/server/src/test/java/org/apache/druid/segment/realtime/plumber/RealtimePlumberSchoolTest.java @@ -214,7 +214,6 @@ public void setUp() throws Exception null, null, null, - true, 0, 0, false, diff --git a/server/src/test/java/org/apache/druid/segment/realtime/plumber/SinkTest.java b/server/src/test/java/org/apache/druid/segment/realtime/plumber/SinkTest.java index 9c7925152b92..de12c4c60b73 100644 --- a/server/src/test/java/org/apache/druid/segment/realtime/plumber/SinkTest.java +++ b/server/src/test/java/org/apache/druid/segment/realtime/plumber/SinkTest.java @@ -78,7 +78,6 @@ public void testSwap() throws Exception null, null, null, - null, 0, 0, null, @@ -235,7 +234,6 @@ public void testDedup() throws Exception null, null, null, - null, 0, 0, null, From b0ef1f56121916ff62757a600d07b408d8a9a785 Mon Sep 17 00:00:00 2001 From: yuanyi Date: Sun, 13 Jun 2021 12:09:41 +0800 Subject: [PATCH 4/5] delete buildV9Directly from hadoop indexing --- docs/ingestion/native-batch.md | 3 +-- .../apache/druid/indexer/HadoopTuningConfig.java | 16 ---------------- .../druid/indexer/BatchDeltaIngestionTest.java | 1 - .../DetermineHashedPartitionsJobTest.java | 1 - .../indexer/DeterminePartitionsJobTest.java | 1 - .../indexer/HadoopDruidIndexerConfigTest.java | 1 - .../druid/indexer/HadoopTuningConfigTest.java | 1 - .../druid/indexer/IndexGeneratorJobTest.java | 1 - .../org/apache/druid/indexer/JobHelperTest.java | 1 - .../indexer/path/GranularityPathSpecTest.java | 1 - 10 files changed, 1 insertion(+), 26 deletions(-) diff --git a/docs/ingestion/native-batch.md b/docs/ingestion/native-batch.md index 7039bfb23330..8fdc3977f63c 100644 --- a/docs/ingestion/native-batch.md +++ b/docs/ingestion/native-batch.md @@ -605,8 +605,7 @@ An example of the result is "logParseExceptions": false, "maxParseExceptions": 2147483647, "maxSavedParseExceptions": 0, - "forceGuaranteedRollup": false, - "buildV9Directly": true + "forceGuaranteedRollup": false } } }, diff --git a/indexing-hadoop/src/main/java/org/apache/druid/indexer/HadoopTuningConfig.java b/indexing-hadoop/src/main/java/org/apache/druid/indexer/HadoopTuningConfig.java index e4b9b5335c36..eefdbb1d3899 100644 --- a/indexing-hadoop/src/main/java/org/apache/druid/indexer/HadoopTuningConfig.java +++ b/indexing-hadoop/src/main/java/org/apache/druid/indexer/HadoopTuningConfig.java @@ -67,7 +67,6 @@ public static HadoopTuningConfig makeDefaultTuningConfig() false, false, null, - true, DEFAULT_NUM_BACKGROUND_PERSIST_THREADS, false, false, @@ -124,8 +123,6 @@ public HadoopTuningConfig( final @JsonProperty("useCombiner") @Nullable Boolean useCombiner, // See https://github.com/apache/druid/pull/1922 final @JsonProperty("rowFlushBoundary") @Nullable Integer maxRowsInMemoryCOMPAT, - // This parameter is left for compatibility when reading existing configs, to be removed in Druid 0.12. - final @JsonProperty("buildV9Directly") Boolean buildV9Directly, final @JsonProperty("numBackgroundPersistThreads") @Nullable Integer numBackgroundPersistThreads, final @JsonProperty("forceExtendableShardSpecs") boolean forceExtendableShardSpecs, final @JsonProperty("useExplicitVersion") boolean useExplicitVersion, @@ -290,16 +287,6 @@ public boolean getUseCombiner() return useCombiner; } - /** - * Always returns true, doesn't affect the version being built. - */ - @Deprecated - @JsonProperty - public Boolean getBuildV9Directly() - { - return true; - } - @JsonProperty public int getNumBackgroundPersistThreads() { @@ -369,7 +356,6 @@ public HadoopTuningConfig withWorkingPath(String path) combineText, useCombiner, null, - true, numBackgroundPersistThreads, forceExtendableShardSpecs, useExplicitVersion, @@ -401,7 +387,6 @@ public HadoopTuningConfig withVersion(String ver) combineText, useCombiner, null, - true, numBackgroundPersistThreads, forceExtendableShardSpecs, useExplicitVersion, @@ -433,7 +418,6 @@ public HadoopTuningConfig withShardSpecs(Map> specs combineText, useCombiner, null, - true, numBackgroundPersistThreads, forceExtendableShardSpecs, useExplicitVersion, diff --git a/indexing-hadoop/src/test/java/org/apache/druid/indexer/BatchDeltaIngestionTest.java b/indexing-hadoop/src/test/java/org/apache/druid/indexer/BatchDeltaIngestionTest.java index 913c6481e577..0871ac3c5455 100644 --- a/indexing-hadoop/src/test/java/org/apache/druid/indexer/BatchDeltaIngestionTest.java +++ b/indexing-hadoop/src/test/java/org/apache/druid/indexer/BatchDeltaIngestionTest.java @@ -483,7 +483,6 @@ private HadoopDruidIndexerConfig makeHadoopDruidIndexerConfig( false, null, null, - null, false, false, null, diff --git a/indexing-hadoop/src/test/java/org/apache/druid/indexer/DetermineHashedPartitionsJobTest.java b/indexing-hadoop/src/test/java/org/apache/druid/indexer/DetermineHashedPartitionsJobTest.java index 1bb672cb36c4..e0ce61246c63 100644 --- a/indexing-hadoop/src/test/java/org/apache/druid/indexer/DetermineHashedPartitionsJobTest.java +++ b/indexing-hadoop/src/test/java/org/apache/druid/indexer/DetermineHashedPartitionsJobTest.java @@ -229,7 +229,6 @@ public DetermineHashedPartitionsJobTest( false, null, null, - null, false, false, null, diff --git a/indexing-hadoop/src/test/java/org/apache/druid/indexer/DeterminePartitionsJobTest.java b/indexing-hadoop/src/test/java/org/apache/druid/indexer/DeterminePartitionsJobTest.java index b73b47cacc1b..9469badc8fb6 100644 --- a/indexing-hadoop/src/test/java/org/apache/druid/indexer/DeterminePartitionsJobTest.java +++ b/indexing-hadoop/src/test/java/org/apache/druid/indexer/DeterminePartitionsJobTest.java @@ -338,7 +338,6 @@ public DeterminePartitionsJobTest( false, null, null, - null, false, false, null, diff --git a/indexing-hadoop/src/test/java/org/apache/druid/indexer/HadoopDruidIndexerConfigTest.java b/indexing-hadoop/src/test/java/org/apache/druid/indexer/HadoopDruidIndexerConfigTest.java index 86e35d08ab9d..aec198a33edb 100644 --- a/indexing-hadoop/src/test/java/org/apache/druid/indexer/HadoopDruidIndexerConfigTest.java +++ b/indexing-hadoop/src/test/java/org/apache/druid/indexer/HadoopDruidIndexerConfigTest.java @@ -251,7 +251,6 @@ HadoopIngestionSpec build() false, null, null, - null, false, false, null, diff --git a/indexing-hadoop/src/test/java/org/apache/druid/indexer/HadoopTuningConfigTest.java b/indexing-hadoop/src/test/java/org/apache/druid/indexer/HadoopTuningConfigTest.java index 230c6c0a949d..0bac6b2206ba 100644 --- a/indexing-hadoop/src/test/java/org/apache/druid/indexer/HadoopTuningConfigTest.java +++ b/indexing-hadoop/src/test/java/org/apache/druid/indexer/HadoopTuningConfigTest.java @@ -57,7 +57,6 @@ public void testSerde() throws Exception true, null, null, - null, true, true, null, diff --git a/indexing-hadoop/src/test/java/org/apache/druid/indexer/IndexGeneratorJobTest.java b/indexing-hadoop/src/test/java/org/apache/druid/indexer/IndexGeneratorJobTest.java index 24ff1227ee58..2e42d5916f06 100644 --- a/indexing-hadoop/src/test/java/org/apache/druid/indexer/IndexGeneratorJobTest.java +++ b/indexing-hadoop/src/test/java/org/apache/druid/indexer/IndexGeneratorJobTest.java @@ -540,7 +540,6 @@ public void setUp() throws Exception false, useCombiner, null, - true, null, forceExtendableShardSpecs, false, diff --git a/indexing-hadoop/src/test/java/org/apache/druid/indexer/JobHelperTest.java b/indexing-hadoop/src/test/java/org/apache/druid/indexer/JobHelperTest.java index 9115eddfc086..6f8e84af086b 100644 --- a/indexing-hadoop/src/test/java/org/apache/druid/indexer/JobHelperTest.java +++ b/indexing-hadoop/src/test/java/org/apache/druid/indexer/JobHelperTest.java @@ -181,7 +181,6 @@ public void setup() throws Exception false, null, null, - null, false, false, null, diff --git a/indexing-hadoop/src/test/java/org/apache/druid/indexer/path/GranularityPathSpecTest.java b/indexing-hadoop/src/test/java/org/apache/druid/indexer/path/GranularityPathSpecTest.java index 8fc3e6c28084..fcecb0bf0782 100644 --- a/indexing-hadoop/src/test/java/org/apache/druid/indexer/path/GranularityPathSpecTest.java +++ b/indexing-hadoop/src/test/java/org/apache/druid/indexer/path/GranularityPathSpecTest.java @@ -73,7 +73,6 @@ public class GranularityPathSpecTest false, null, null, - null, false, false, null, From 5582a04aa8607e2aa7654eca2888d41d9fad0191 Mon Sep 17 00:00:00 2001 From: yuanyi Date: Fri, 18 Jun 2021 17:01:09 +0800 Subject: [PATCH 5/5] bug fixed --- .../materializedview/MaterializedViewSupervisorSpec.java | 1 - .../apache/druid/indexing/kafka/KafkaIndexTaskTuningConfig.java | 1 - .../druid/indexing/kinesis/KinesisIndexTaskTuningConfig.java | 1 - .../apache/druid/indexing/common/task/RealtimeIndexTaskTest.java | 1 - .../org/apache/druid/indexing/common/task/TaskSerdeTest.java | 1 - .../org/apache/druid/indexing/overlord/TaskLifecycleTest.java | 1 - .../seekablestream/SeekableStreamSupervisorSpecTest.java | 1 - .../supervisor/SeekableStreamSupervisorStateTest.java | 1 - .../org/apache/druid/cli/validate/DruidJsonValidatorTest.java | 1 - 9 files changed, 9 deletions(-) diff --git a/extensions-contrib/materialized-view-maintenance/src/main/java/org/apache/druid/indexing/materializedview/MaterializedViewSupervisorSpec.java b/extensions-contrib/materialized-view-maintenance/src/main/java/org/apache/druid/indexing/materializedview/MaterializedViewSupervisorSpec.java index be21a6558fff..6daaad9d73e3 100644 --- a/extensions-contrib/materialized-view-maintenance/src/main/java/org/apache/druid/indexing/materializedview/MaterializedViewSupervisorSpec.java +++ b/extensions-contrib/materialized-view-maintenance/src/main/java/org/apache/druid/indexing/materializedview/MaterializedViewSupervisorSpec.java @@ -192,7 +192,6 @@ public HadoopIndexTask createTask(Interval interval, String version, List