Repository: incubator-apex-malhar Updated Branches: refs/heads/master 08cb9d3b3 -> 2138512bb
APEXMALHAR-2068 made noop default in FileSplitter 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/2138512b Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/2138512b Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/2138512b Branch: refs/heads/master Commit: 2138512bb9747bcbec09226ba459031219f198a3 Parents: 08cb9d3 Author: Chandni Singh <csi...@apache.org> Authored: Fri Apr 29 11:23:02 2016 -0700 Committer: Chandni Singh <csi...@apache.org> Committed: Fri Apr 29 11:30:58 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java | 2 +- .../test/java/com/datatorrent/lib/io/fs/FileSplitterInputTest.java | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/2138512b/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 686f116..b7b674e 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 @@ -96,7 +96,7 @@ public class FileSplitterInput extends AbstractFileSplitter implements InputOper { super(); currentWindowRecoveryState = Lists.newLinkedList(); - idempotentStorageManager = new IdempotentStorageManager.FSIdempotentStorageManager(); + idempotentStorageManager = new IdempotentStorageManager.NoopIdempotentStorageManager(); referenceTimes = Maps.newHashMap(); scanner = new TimeBasedDirectoryScanner(); } http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/2138512b/library/src/test/java/com/datatorrent/lib/io/fs/FileSplitterInputTest.java ---------------------------------------------------------------------- diff --git a/library/src/test/java/com/datatorrent/lib/io/fs/FileSplitterInputTest.java b/library/src/test/java/com/datatorrent/lib/io/fs/FileSplitterInputTest.java index 035ed07..4df0b12 100644 --- a/library/src/test/java/com/datatorrent/lib/io/fs/FileSplitterInputTest.java +++ b/library/src/test/java/com/datatorrent/lib/io/fs/FileSplitterInputTest.java @@ -108,7 +108,6 @@ public class FileSplitterInputTest fileSplitterInput.getScanner().setScanIntervalMillis(500); fileSplitterInput.getScanner().setFilePatternRegularExp(".*[.]txt"); fileSplitterInput.getScanner().setFiles(dataDirectory); - fileSplitterInput.setIdempotentStorageManager(new IdempotentStorageManager.NoopIdempotentStorageManager()); Attribute.AttributeMap.DefaultAttributeMap attributes = new Attribute.AttributeMap.DefaultAttributeMap(); attributes.put(Context.DAGContext.APPLICATION_PATH,
