You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Oleg Zhurakousky (JIRA)" <ji...@apache.org> on 2016/11/20 15:01:58 UTC
[jira] [Commented] (NIFI-3066) MergeContent: "Cannot migrate
FlowFiles from a Process Session to itself"
[ https://issues.apache.org/jira/browse/NIFI-3066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15681278#comment-15681278 ]
Oleg Zhurakousky commented on NIFI-3066:
----------------------------------------
[~markap14] It's marked "Patch Available" but no patch is attached/linked.
> 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)