NIFI-259: Do not require the State File anymore, since state management is being used now
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/d6a21537 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/d6a21537 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/d6a21537 Branch: refs/heads/NIFI-259 Commit: d6a21537c19f98039735d407e9d52224ab39acf5 Parents: 16dcf45 Author: Mark Payne <[email protected]> Authored: Tue Jan 19 11:03:31 2016 -0500 Committer: Mark Payne <[email protected]> Committed: Tue Jan 19 11:03:31 2016 -0500 ---------------------------------------------------------------------- .../main/java/org/apache/nifi/processors/standard/TailFile.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/d6a21537/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java index 42a6aab..659527c 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java @@ -123,7 +123,7 @@ public class TailFile extends AbstractProcessor { .description("Specifies the file that should be used for storing state about what data has been ingested so that upon restart NiFi can resume from where it left off") .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) .expressionLanguageSupported(false) - .required(true) + .required(false) .build(); static final PropertyDescriptor START_POSITION = new PropertyDescriptor.Builder() .name("Initial Start Position") @@ -148,7 +148,7 @@ public class TailFile extends AbstractProcessor { final List<PropertyDescriptor> properties = new ArrayList<>(); properties.add(FILENAME); properties.add(ROLLING_FILENAME_PATTERN); - properties.add(new PropertyDescriptor.Builder().fromPropertyDescriptor(STATE_FILE).defaultValue("./conf/state/" + getIdentifier()).build()); + properties.add(STATE_FILE); properties.add(START_POSITION); properties.add(FILE_LOCATION); return properties;
