diff --git a/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java b/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java index 7b4ed9fd1df..99d9a10c2c6 100644 --- a/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java +++ b/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java @@ -75,7 +75,7 @@ public class JobHelper final Path hdfsPath = new Path(distributedClassPath, jarFile.getName()); if (!existing.contains(hdfsPath)) { - if (jarFile.getName().endsWith("SNAPSHOT.jar") || !fs.exists(hdfsPath)) { + if (jarFile.getName().matches(".*SNAPSHOT(-selfcontained)?\\.jar$") || !fs.exists(hdfsPath)) { log.info("Uploading jar to path[%s]", hdfsPath); ByteStreams.copy( Files.newInputStreamSupplier(jarFile),