diff --git a/indexing-service/src/main/java/io/druid/indexing/common/task/HadoopIndexTask.java b/indexing-service/src/main/java/io/druid/indexing/common/task/HadoopIndexTask.java index bf609c81e44..730a4a8f7aa 100644 --- a/indexing-service/src/main/java/io/druid/indexing/common/task/HadoopIndexTask.java +++ b/indexing-service/src/main/java/io/druid/indexing/common/task/HadoopIndexTask.java @@ -150,8 +150,8 @@ public class HadoopIndexTask extends AbstractTask Thread.currentThread().setContextClassLoader(loader); final Set jobUrls = Sets.newHashSet(); - jobUrls.addAll(extensionURLs); jobUrls.addAll(nonHadoopURLs); + jobUrls.addAll(extensionURLs); System.setProperty("druid.hadoop.internal.classpath", Joiner.on(File.pathSeparator).join(jobUrls)); diff --git a/services/src/main/java/io/druid/cli/CliHadoopIndexer.java b/services/src/main/java/io/druid/cli/CliHadoopIndexer.java index 0ded97961b9..187cd341fb3 100644 --- a/services/src/main/java/io/druid/cli/CliHadoopIndexer.java +++ b/services/src/main/java/io/druid/cli/CliHadoopIndexer.java @@ -88,8 +88,8 @@ public class CliHadoopIndexer implements Runnable Thread.currentThread().setContextClassLoader(loader); final Set jobUrls = Sets.newHashSet(); - jobUrls.addAll(extensionURLs); jobUrls.addAll(nonHadoopURLs); + jobUrls.addAll(extensionURLs); System.setProperty("druid.hadoop.internal.classpath", Joiner.on(File.pathSeparator).join(jobUrls));