adamdebreceni commented on a change in pull request #829:
URL: https://github.com/apache/nifi-minifi-cpp/pull/829#discussion_r450121956
##########
File path: extensions/rocksdb-repos/FlowFileRepository.cpp
##########
@@ -152,7 +153,10 @@ void FlowFileRepository::prune_stored_flowfiles() {
// we find the connection for the persistent flowfile, create the
flowfile and enqueue that
std::shared_ptr<core::FlowFile> flow_file_ref =
std::static_pointer_cast<core::FlowFile>(eventRead);
eventRead->setStoredToRepository(true);
- search->second->put(eventRead);
+ auto connection = std::static_pointer_cast<Connection>(search->second);
Review comment:
if #807 is merged Processors can also be FlowFile containers (like
`BinFiles`) and those files should also be restored
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
