[
https://issues.apache.org/jira/browse/NIFI-8461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17342412#comment-17342412
]
KevinSky edited comment on NIFI-8461 at 5/11/21, 8:39 AM:
----------------------------------------------------------
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 should transfer to REL_SUCESS
. When I debug this , I found 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
was (Author: kevinsky1093):
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)
