This is an automated email from the ASF dual-hosted git repository.
atul pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new 3785ad5 Add log message when local input's filter does not match any
files (#10837)
3785ad5 is described below
commit 3785ad5812f1ab1c2a20a409eefa13d259f49dca
Author: Agustin Gonzalez <[email protected]>
AuthorDate: Fri Feb 5 10:35:19 2021 -0700
Add log message when local input's filter does not match any files (#10837)
* Add log message when local input's filter does not match any files
* Re-use previously defined fileIterator
---
.../org/apache/druid/data/input/impl/LocalInputSource.java | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
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 04b7dc7..c765717 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.InputSourceReader;
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 @@ import java.util.stream.Stream;
public class LocalInputSource extends AbstractInputSource implements
SplittableInputSource<List<File>>
{
+ private static final Logger log = new Logger(LocalInputSource.class);
+
@Nullable
private final File baseDir;
@Nullable
@@ -151,11 +154,17 @@ public class LocalInputSource extends AbstractInputSource
implements SplittableI
)
);
}
- return FileUtils.iterateFiles(
+ Iterator<File> 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;
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
