[
https://issues.apache.org/jira/browse/NIFI-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417386#comment-15417386
]
Michael Moser edited comment on NIFI-2551 at 8/11/16 3:07 PM:
--------------------------------------------------------------
I have a patch that provides extra synchronization in the FileSystemRepository
public methods incrementClaimantCount(), getClaimantCount(), and
decrementClaimantCount(). This helps synchronize the state of the claim counts
in resourceClaimManager and the ResourceClaims stored in writableClaimQueue.
This patch did fix the problem on a NiFi system that actually saw this NPE
regularly.
But now I'm thinking perhaps more needs to be done in
StandardProcessSession.removeTemporaryClaim() and destroyContent() to operate
on the FileSystemRepository more atomically.
was (Author: mosermw):
I have a patch that provides extra synchronization in the FileSystemRepository
public methods incrementClaimantCount(), getClaimantCount(), and
decrementClaimantCount(). This helps synchronize the state of the claim counts
in resourceClaimManager and the ResourceClaims stored in writableClaimQueue.
This patch did fix the problem on a NiFi system that actually saw this NPE
regularly.
But now I'm thinking perhaps more needs to be done in
StandardProcessSession.removeTemporaryClaim() and destroyContent() to operate
on the FileSystemRepository more atmoically.
> Rare condition causes FileSystemRepository NPE
> ----------------------------------------------
>
> Key: NIFI-2551
> URL: https://issues.apache.org/jira/browse/NIFI-2551
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 1.0.0, 0.7.0
> Reporter: Michael Moser
> Priority: Blocker
>
> In rare unpredictable cases when NiFi is processing a heavy load, we see
> FileSystemRepository throw a NullPointerException
> {noformat}
> java.lang.NullPointerException
> at o.a.n.c.r.FileSystemRepository$2.write(FileSystemRepository.java:919)
> [nifi-framework-core-0.7.0.jar]
> at
> o.a.n.c.r.io.DisableOnCloseOutputStream.write(DisableOnCloseOutputStream.java:49)
> ....
> Suppressed: java.lang.NullPointerException
> at
> o.a.n.c.r.FileSystemRepository$2.flush(FileSystemRepository.java:935)
> [nifi-framework-core-0.7.0.jar]
> at
> o.a.n.c.r.io.DisableOnCloseOutputStream.close(DisableOnCloseOutputStream.java:68)
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
