[ 
https://issues.apache.org/jira/browse/NIFI-8461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17342412#comment-17342412
 ] 

KevinSky commented on NIFI-8461:
--------------------------------

hi [#Mark Payne],here is my script text:
{code:java}
// 
import os
userCountFile = "D:\\99_TestCase\\3_StuckTest\\B5_ALL_CELL_USER_COUNT_"
try:
    flowFile = session.get()
    if (flowFile != None):
        filename = flowFile.getAttribute('filename')
        userCountName = userCountFile + filename[12:]
        #flowFile = session.putAttribute(flowFile, 'userCountName', 
userCountName)
        if os.path.exists(userCountName):
            session.transfer(flowFile, REL_SUCCESS)
        else:
            session.transfer(flowFile, REL_FAILURE)
    else:
        pass
except Exception as e:
    log.error('Error!')
else:
    pass
finally:
    pass
{code}
I'm sure that the flowFile is in the path, so it normally remove by 
StandardProcessSeesion::unacknowledgedFlowFiles();but in this situation, I 
found but not sure that the unacknowledgedFlowFiles in 
StandardProcessSeesion::acknowledgeRecords() was empty,or recordMap never be 
puted in StandardProcessSeesion::commit().

best whishes

 

 

> 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
>            Assignee: Matt Burgess
>            Priority: Major
>              Labels: queue
>         Attachments: ExecuteScript_Queue_Issue.txt, NIFI-8461.zip, 
> image-2021-04-22-08-48-58-117.png, image-2021-04-22-08-49-40-904.png, 
> image-2021-04-27-14-23-07-849.png, image-2021-04-27-14-23-24-477.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)

Reply via email to