Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-17 07:25:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix more test breakage

Browse Source
This commit is contained in:
fjy 2014-06-17 10:35:01 -07:00
parent 8a13e34c50
commit 5227b43050
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
indexing-service/src/test/java/io/druid/indexing/worker/WorkerTaskMonitorTest.java
View File

@ -121,7 +121,7 @@ public class WorkerTaskMonitorTest
workerCuratorCoordinator, workerCuratorCoordinator,
new ThreadPoolTaskRunner( new ThreadPoolTaskRunner(
new TaskToolboxFactory( new TaskToolboxFactory(
new TaskConfig(tmp.toString(), null, null, 0), new TaskConfig(tmp.toString(), null, null, 0, null),
null, null, null, null, null, null, null, null, null, null, null, new SegmentLoaderFactory( null, null, null, null, null, null, null, null, null, null, null, new SegmentLoaderFactory(
new OmniSegmentLoader( new OmniSegmentLoader(
ImmutableMap.<String, DataSegmentPuller>of( ImmutableMap.<String, DataSegmentPuller>of(

3
services/src/main/java/io/druid/cli/PullDependencies.java
View File

@ -24,6 +24,7 @@ import com.google.common.base.Throwables;
import com.google.inject.Inject; import com.google.inject.Inject;
import io.airlift.command.Command; import io.airlift.command.Command;
import io.airlift.command.Option; import io.airlift.command.Option;
import io.druid.indexing.common.config.TaskConfig;
import io.druid.indexing.common.task.HadoopIndexTask; import io.druid.indexing.common.task.HadoopIndexTask;
import io.druid.initialization.Initialization; import io.druid.initialization.Initialization;
import io.druid.server.initialization.ExtensionsConfig; import io.druid.server.initialization.ExtensionsConfig;
@ -62,7 +63,7 @@ public class PullDependencies implements Runnable
allCoordinates.addAll(coordinates); allCoordinates.addAll(coordinates);
} }
if (!noDefaultHadoop) { if (!noDefaultHadoop) {
allCoordinates.add(HadoopIndexTask.DEFAULT_HADOOP_COORDINATES); allCoordinates.addAll(TaskConfig.DEFAULT_DEFAULT_HADOOP_COORDINATES);
} }
try { try {
final DefaultTeslaAether aetherClient = Initialization.getAetherClient(extensionsConfig); final DefaultTeslaAether aetherClient = Initialization.getAetherClient(extensionsConfig);