Repository: incubator-apex-malhar Updated Branches: refs/heads/devel-3 54106d414 -> 08deae6db
MLHR-1918: [FileSplitter] Need stopScanning method in Scanner 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/183d3c2c Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/183d3c2c Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/183d3c2c Branch: refs/heads/devel-3 Commit: 183d3c2cb75c496c11d18177b26e2b5b44527444 Parents: 217f8db Author: Priyanka Gugale <[email protected]> Authored: Wed Nov 25 14:54:38 2015 +0530 Committer: Priyanka Gugale <[email protected]> Committed: Thu Nov 26 14:13:20 2015 +0530 ---------------------------------------------------------------------- .../java/com/datatorrent/lib/io/fs/FileSplitterInput.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/183d3c2c/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 361bdab..ab70047 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 @@ -323,10 +323,18 @@ public class FileSplitterInput extends AbstractFileSplitter implements InputOper scanService.submit(this); } + /** + * Stop scanner + */ + protected void stopScanning() + { + running = false; + } + @Override public void teardown() { - running = false; + stopScanning(); scanService.shutdownNow(); try { fs.close();
