Repository: nifi-minifi-cpp Updated Branches: refs/heads/master 8ed4ab6a6 -> 8c110e9fe
MINIFI-114: Set default stateFile for TailFile This closes #24. Signed-off-by: Aldrin Piri <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/commit/8c110e9f Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/8c110e9f Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/8c110e9f Branch: refs/heads/master Commit: 8c110e9fe1875cbf602812132505dbe60fe46c86 Parents: 8ed4ab6 Author: Bin Qiu <[email protected]> Authored: Tue Nov 22 20:51:12 2016 -0800 Committer: Aldrin Piri <[email protected]> Committed: Mon Nov 28 14:51:16 2016 -0500 ---------------------------------------------------------------------- libminifi/src/TailFile.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/8c110e9f/libminifi/src/TailFile.cpp ---------------------------------------------------------------------- diff --git a/libminifi/src/TailFile.cpp b/libminifi/src/TailFile.cpp index 445255b..0b389c7 100644 --- a/libminifi/src/TailFile.cpp +++ b/libminifi/src/TailFile.cpp @@ -41,7 +41,7 @@ const std::string TailFile::ProcessorName("TailFile"); Property TailFile::FileName("File to Tail", "Fully-qualified filename of the file that should be tailed", ""); Property TailFile::StateFile("State File", - "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", ""); + "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", "TailFileState"); Relationship TailFile::Success("success", "All files are routed to success"); void TailFile::initialize() @@ -230,7 +230,7 @@ void TailFile::onTrigger(ProcessContext *context, ProcessSession *session) } if (context->getProperty(StateFile.getName(), value)) { - _stateFile = value; + _stateFile = value + "." + getUUIDStr(); } if (!this->_stateRecovered) {
