Hi Richard,

Does the service take more than 5 minutes before it responds? Then your socket 
idle timeout might cause the connection to be closed. Try setting that to 
higher than the read timeout.

Regards,

Isha

Van: Richard Beare <[email protected]>
Verzonden: woensdag 15 maart 2023 03:54
Aan: [email protected]
Onderwerp: Broken pipe: InvokeHTTP

Hi Everyone,
I have an InvokeHTTP processor experiencing the error below on a small 
proportion of flowfiles. The service it is accessing is running on another 
docker on the same host, and I've adjusted the frequency of requests to quite 
low - the processor is running single threaded. The settings are pretty 
standard - socket connect timeout 5 s, socket read timeout 600 sec, socket idle 
timeout 5mins, socket idle connections 5. The processor is on a 1s schedule (I 
don't want it to be that slow). My nifi setup is not clustered.

Googling suggests that the error could be caused by lack of disk space, but 
that doesn't appear to be the case (all the nifi storage is on a drive with 
plenty of space).

What else should I be looking for? The operation does take a while to run, but 
nowhere near 10minutes. I've configured the web service to support several 
workers with the intention of processing many flowfiles quickly, but this error 
is limiting what I can do. Sending the unsuccessful flowfiles to the service 
using curl does wotk, so not a problem with the data.

Any ideas?

2023-03-14 01:48:46,334 ERROR [Timer-Driven Process Thread-36] 
o.a.nifi.processors.standard.InvokeHTTP 
InvokeHTTP[id=cb72d2e0-d5c0-36c1-19b6-13a542a56e60] Request Processing failed: 
StandardFlowFileRecord[uuid=eff900e7-81ce-4312-abe2-218cb78d3ca1,claim=StandardContentClaim
 [resourceClaim=StandardResourceClaim[id=1678758435916-5, container=default, 
section=5], offset=11133732, 
length=125544],offset=0,name=eff900e7-81ce-4312-abe2-218cb78d3ca1,size=125544]
org.apache.nifi.processor.exception.ProcessException: IOException thrown from 
InvokeHTTP[id=cb72d2e0-d5c0-36c1-19b6-13a542a56e60]: java.net.SocketException: 
Broken pipe (Write failed)
at 
org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2716)
at 
org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2661)
at 
org.apache.nifi.processors.standard.InvokeHTTP$1.writeTo(InvokeHTTP.java:1170)
at 
okhttp3.internal.http.CallServerInterceptor.intercept(CallServerInterceptor.kt:59)
at 
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)

Reply via email to