Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix another broken ut

This commit is contained in:
fjy 2014-12-09 15:47:28 -08:00
parent 7620dfbd1a
commit 123db3da4d
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
indexing-service/src/main/java/io/druid/indexing/common/task/HadoopIndexTask.java
View File

@ -66,6 +66,7 @@ public class HadoopIndexTask extends AbstractTask
private static final ExtensionsConfig extensionsConfig; private static final ExtensionsConfig extensionsConfig;
final static Injector injector = GuiceInjectors.makeStartupInjector(); final static Injector injector = GuiceInjectors.makeStartupInjector();
static { static {
extensionsConfig = injector.getInstance(ExtensionsConfig.class); extensionsConfig = injector.getInstance(ExtensionsConfig.class);
} }
@ -85,7 +86,7 @@ public class HadoopIndexTask extends AbstractTask
/** /**
* @param spec is used by the HadoopDruidIndexerJob to set up the appropriate parameters * @param spec is used by the HadoopDruidIndexerJob to set up the appropriate parameters
* for creating Druid index segments. It may be modified. * for creating Druid index segments. It may be modified.
* * <p/>
* Here, we will ensure that the DbConnectorConfig field of the spec is set to null, such that the * Here, we will ensure that the DbConnectorConfig field of the spec is set to null, such that the
* job does not push a list of published segments the database. Instead, we will use the method * job does not push a list of published segments the database. Instead, we will use the method
* IndexGeneratorJob.getPublishedSegments() to simply return a list of the published * IndexGeneratorJob.getPublishedSegments() to simply return a list of the published
@ -110,11 +111,13 @@ public class HadoopIndexTask extends AbstractTask
this.spec = spec; this.spec = spec;
// Some HadoopIngestionSpec stuff doesn't make sense in the context of the indexing service // Some HadoopIngestionSpec stuff doesn't make sense in the context of the indexing service
if (this.spec.getTuningConfig().getWorkingPath() != null) {
log.error("workingPath should be absent in your spec! Ignoring");
}
Preconditions.checkArgument( Preconditions.checkArgument(
this.spec.getIOConfig().getSegmentOutputPath() == null, this.spec.getIOConfig().getSegmentOutputPath() == null,
"segmentOutputPath must be absent" "segmentOutputPath must be absent"
); );
Preconditions.checkArgument(this.spec.getTuningConfig().getWorkingPath() == null, "workingPath must be absent");
Preconditions.checkArgument( Preconditions.checkArgument(
this.spec.getIOConfig().getMetadataUpdateSpec() == null, this.spec.getIOConfig().getMetadataUpdateSpec() == null,
"metadataUpdateSpec must be absent" "metadataUpdateSpec must be absent"