[
https://issues.apache.org/jira/browse/NIFI-3066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Zhurakousky updated NIFI-3066:
-----------------------------------
Resolution: Fixed
Status: Resolved (was: Patch Available)
> MergeContent: "Cannot migrate FlowFiles from a Process Session to itself"
> -------------------------------------------------------------------------
>
> Key: NIFI-3066
> URL: https://issues.apache.org/jira/browse/NIFI-3066
> Project: Apache NiFi
> Issue Type: Bug
> Affects Versions: 1.1.0
> Reporter: Joseph Gresock
> Assignee: Mark Payne
> Priority: Critical
> Fix For: 1.1.0
>
>
> With the following properties in MergeContent, I get this error when I try to
> process a flow file (which is 135MB):
> Merge Strategy = Bin-Packing Algorithm
> Merge Format = ZIP
> Attribute Strategy = Keep Only Common Attributes
> Correlation Attribute Name = bundle.identifier
> Minimum Number of Entries = 200
> Maximum Number of Entries = 200
> Minimum Group Size = 20 MB
> Maximum Group Size = *20 MB*
> Max Bin Age = 1 min
> Maximum number of Bins = 100
> Delimiter Strategy = Filename
> Keep Path = false
> {code}
> 016-11-18 18:00:13,752 ERROR [Timer-Driven Process Thread-83]
> o.a.n.processors.standard.MergeContent
> java.lang.IllegalArgumentException: Cannot migrate FlowFiles from a Process
> Session to itself
> at
> org.apache.nifi.controller.repository.StandardProcessSession.migrate(StandardProcessSession.java:1091)
> ~[nifi-framework-core-1.1.0-SNAPSHOT.jar:1.1.0-SNAPSHOT]
> at org.apache.nifi.processor.util.bin.Bin.offer(Bin.java:142)
> ~[nifi-processor-utils-1.1.0-SNAPSHOT.jar:1.1.0-SNAPSHOT]
> at
> org.apache.nifi.processor.util.bin.BinFiles.binFlowFiles(BinFiles.java:282)
> ~[nifi-processor-utils-1.1.0-SNAPSHOT.jar:1.1.0-SNAPSHOT]
> at
> org.apache.nifi.processor.util.bin.BinFiles.onTrigger(BinFiles.java:178)
> ~[nifi-processor-utils-1.1.0-SNAPSHOT.jar:1.1.0-SNAPSHOT]
> at
> org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1089)
> ~[nifi-framework-core-1.1.0-SNAPSHOT.jar:1.1.0-SNAPSHOT]
> ...
> 2016-11-18 18:00:13,753 WARN [Timer-Driven Process Thread-83]
> o.a.n.processors.standard.MergeContent
> MergeContent[id=a9476272-dab0-3d2f-acef-abf11f7d1b80] Processor
> Administratively Yielded for 1 sec due to processing failure
> {code}
> However, other smaller flow files are able to successfully go through the
> processor. Not sure if it's related to the size of the flow file or not.
> Perhaps there just needs to be a check around this line in Bin.java:142, to
> make sure we don't try to migrate a flow file to its own session:
> {code}
> session.migrate(getSession(), Collections.singleton(flowFile));
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
