diff --git a/core/src/main/java/org/apache/druid/data/input/impl/LocalInputSource.java b/core/src/main/java/org/apache/druid/data/input/impl/LocalInputSource.java index 04b7dc7b2cd9..c765717b3a1a 100644 --- a/core/src/main/java/org/apache/druid/data/input/impl/LocalInputSource.java +++ b/core/src/main/java/org/apache/druid/data/input/impl/LocalInputSource.java @@ -40,6 +40,7 @@ import org.apache.druid.data.input.InputSplit; import org.apache.druid.data.input.SplitHintSpec; import org.apache.druid.java.util.common.IAE; +import org.apache.druid.java.util.common.logger.Logger; import org.apache.druid.utils.CollectionUtils; import org.apache.druid.utils.Streams; @@ -56,6 +57,8 @@ public class LocalInputSource extends AbstractInputSource implements SplittableInputSource> { + private static final Logger log = new Logger(LocalInputSource.class); + @Nullable private final File baseDir; @Nullable @@ -151,11 +154,17 @@ private Iterator getDirectoryListingIterator() ) ); } - return FileUtils.iterateFiles( + Iterator fileIterator = FileUtils.iterateFiles( baseDir.getAbsoluteFile(), fileFilter, TrueFileFilter.INSTANCE ); + if (!fileIterator.hasNext()) { + // base dir & filter are guaranteed to be non-null here + // (by construction and non-null check of baseDir a few lines above): + log.info("Local inputSource filter [%s] for base dir [%s] did not match any files", filter, baseDir); + } + return fileIterator; } }