diff --git a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/ByteArrayContentRepository.java b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/ByteArrayContentRepository.java index 39baaea2ed..e32aa738b3 100644 --- a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/ByteArrayContentRepository.java +++ b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/ByteArrayContentRepository.java @@ -215,12 +215,16 @@ public class ByteArrayContentRepository implements ContentRepository { @Override public InputStream read(final ContentClaim claim) { + if (claim == null) { + return new ByteArrayInputStream(new byte[0]); + } + final ByteArrayContentClaim byteArrayContentClaim = verifyClaim(claim); return byteArrayContentClaim.read(); } @Override - public InputStream read(final ResourceClaim claim) throws IOException { + public InputStream read(final ResourceClaim claim) { if (claim == null) { return new ByteArrayInputStream(new byte[0]); }