fix some config bugs

This commit is contained in:
fjy 2013-04-23 13:16:50 -07:00
parent 70937af7bd
commit 7184e528fd
3 changed files with 5 additions and 9 deletions

View File

@ -376,10 +376,6 @@ public class InfoResource
@QueryParam("interval") final String interval @QueryParam("interval") final String interval
) )
{ {
// TODO: will likely be all rewritten once Guice introduced
if (indexingServiceClient == null) {
return Response.status(Response.Status.OK).entity(ImmutableMap.of("error", "no indexing service found")).build();
}
if (kill != null && Boolean.valueOf(kill)) { if (kill != null && Boolean.valueOf(kill)) {
indexingServiceClient.killSegments(dataSourceName, new Interval(interval)); indexingServiceClient.killSegments(dataSourceName, new Interval(interval));
} else { } else {

View File

@ -178,15 +178,15 @@ public class MasterMain
lifecycle lifecycle
); );
IndexingServiceClient indexingServiceClient = null; ServiceProvider serviceProvider = null;
if (druidMasterConfig.getMergerServiceName() != null) { if (druidMasterConfig.getMergerServiceName() != null) {
ServiceProvider serviceProvider = Initialization.makeServiceProvider( serviceProvider = Initialization.makeServiceProvider(
druidMasterConfig.getMergerServiceName(), druidMasterConfig.getMergerServiceName(),
serviceDiscovery, serviceDiscovery,
lifecycle lifecycle
); );
indexingServiceClient = new IndexingServiceClient(httpClient, jsonMapper, serviceProvider);
} }
IndexingServiceClient indexingServiceClient = new IndexingServiceClient(httpClient, jsonMapper, serviceProvider);
final DruidClusterInfo druidClusterInfo = new DruidClusterInfo( final DruidClusterInfo druidClusterInfo = new DruidClusterInfo(
configFactory.build(DruidClusterInfoConfig.class), configFactory.build(DruidClusterInfoConfig.class),

View File

@ -60,13 +60,13 @@ public abstract class DruidMasterConfig
@Config("druid.master.merger.on") @Config("druid.master.merger.on")
public boolean isMergeSegments() public boolean isMergeSegments()
{ {
return true; return false;
} }
@Config("druid.master.conversion.on") @Config("druid.master.conversion.on")
public boolean isConvertSegments() public boolean isConvertSegments()
{ {
return true; return false;
} }
@Config("druid.master.merger.service") @Config("druid.master.merger.service")