[
https://issues.apache.org/jira/browse/NIFI-8461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330444#comment-17330444
]
Kevin Aagaard commented on NIFI-8461:
-------------------------------------
# This processor will route the flow into the REL_FAILURE relationship
penalizing if for 2h the 1st time
# after 2h the processor will route the flowfile into the success relationship.
flowfile = session.get()
if flowfile is not None:
waitState = flowfile.getAttribute( '_wait_state' )
# this process has no wait_state Set, so set it and penalize it
if waitState is None:
flowfile = session.putAttribute( flowfile, '_wait_state', '1' )
flowfile = session.penalize(flowfile)
session.transfer( flowfile, REL_FAILURE )
# this flowfile has already penalized
else:
flowfile = session.removeAttribute( flowfile, '_wait_state' )
session.transfer( flowfile, REL_SUCCESS )
> Queue reports items but cannot list them
> ----------------------------------------
>
> Key: NIFI-8461
> URL: https://issues.apache.org/jira/browse/NIFI-8461
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 1.13.2
> Environment: Docker image apache/nifi :1.13.2, Windows 10 Pro, WSL 2
> (Ubuntu), x86_64
> Reporter: Kevin Aagaard
> Priority: Major
> Labels: queue
> Attachments: image-2021-04-22-08-48-58-117.png,
> image-2021-04-22-08-49-40-904.png
>
>
> The following segment of workflow demonstrates the issue. The queue reports
> that there are items within it, but they cannot be listed, even after
> stopping the consumer (and producer). Since this is in a Docker Container, it
> is unlikely an OS error.
>
> !image-2021-04-22-08-48-58-117.png!
>
> !image-2021-04-22-08-49-40-904.png!
> I do not currently have a simplified example workflow to recreate the error,
> but can work on it.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
