APEXMALHAR-2005 fix for timebased directory scanner's paths passing validation even when empty
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/1dc105ce Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/1dc105ce Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/1dc105ce Branch: refs/heads/devel-3 Commit: 1dc105ce091a3f02ec813b0b1ae31310ac076e8f Parents: c3f6951 Author: Chandni Singh <[email protected]> Authored: Fri Apr 1 17:23:16 2016 -0700 Committer: Chandni Singh <[email protected]> Committed: Fri Apr 1 18:07:15 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/1dc105ce/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java b/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java index a732e80..686f116 100644 --- a/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java +++ b/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java @@ -34,6 +34,7 @@ import java.util.regex.Matcher; import java.util.regex.Pattern; import javax.annotation.Nullable; +import javax.validation.Valid; import javax.validation.constraints.Min; import javax.validation.constraints.NotNull; import javax.validation.constraints.Size; @@ -83,6 +84,7 @@ public class FileSplitterInput extends AbstractFileSplitter implements InputOper @NotNull protected final transient LinkedList<ScannedFileInfo> currentWindowRecoveryState; + @Valid @NotNull private TimeBasedDirectoryScanner scanner; @NotNull
