HTTP Event Listener intermittently fails with Broken pipe

[jonsnowseven]

I’m using the HTTP Event Listener with the following configuration:

# query-completed-event-listener.properties
event-listener.name=http
http-event-listener.log-completed=true
http-event-listener.connect-ingest-uri=http://localhost:8000/query-event/query-completed
http-event-listener.connect-retry-count=5

From time to time I see errors like this, and my service never receives the request:

2025-11-13T16:01:17.208Z ERROR http-event-listener-0 io.trino.plugin.httpquery.HttpEventListener
QueryId = "20251113_154243_10214_ax3jg", attempt = 6/6, URL = http://localhost:8000/query-event/query-completed | Error sending HTTP request
java.io.UncheckedIOException: Failed communicating with server: http://localhost:8000/query-event/query-completed
Caused by: org.eclipse.jetty.io.EofException
Caused by: java.io.IOException: Broken pipe
    at org.eclipse.jetty.io.SocketChannelEndPoint.flush(SocketChannelEndPoint.java:112)
    at java.nio.channels.SocketChannel.write(SocketChannel.java:660)
    ...

It looks like a server-side timeout/connection drop, but I’d like to confirm. Specifically, I want visibility into what the client is sending and what (if anything) it’s getting back (status code, response body, headers).

Questions

1. Is there a way to enable verbose HTTP logging for the event listener client (Jetty/Airlift) so I can see the outbound payload and the server’s response?
2. Are there additional listener/client settings I can tweak (timeouts, retries, backoff) that might help diagnose or mitigate the Broken pipe errors?

Environment

• Trino version: 469
• Endpoint: http://localhost:8000/query-event/query-completed

Full stack trace excerpt for reference:

... 36 more
	at org.eclipse.jetty.io.SocketChannelEndPoint.flush(SocketChannelEndPoint.java:112)
	at java.base/java.nio.channels.SocketChannel.write(SocketChannel.java:660)
	at java.base/sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:631)
	at java.base/sun.nio.ch.SocketChannelImpl.implWrite(SocketChannelImpl.java:597)
	at java.base/sun.nio.ch.IOUtil.write(IOUtil.java:158)
	at java.base/sun.nio.ch.IOUtil.write(IOUtil.java:227)
	at java.base/sun.nio.ch.SocketDispatcher.writev(SocketDispatcher.java:66)
	at java.base/sun.nio.ch.SocketDispatcher.writev0(Native Method)
Caused by: java.io.IOException: Broken pipe
	... 26 more
	at org.eclipse.jetty.util.IteratingCallback.processing(IteratingCallback.java:262)
	at org.eclipse.jetty.client.transport.HttpSender$ContentSender.process(HttpSender.java:569)
	at org.eclipse.jetty.client.transport.internal.HttpSenderOverHTTP.sendHeaders(HttpSenderOverHTTP.java:78)
	at org.eclipse.jetty.util.IteratingCallback.iterate(IteratingCallback.java:243)
	at org.eclipse.jetty.util.IteratingCallback.processing(IteratingCallback.java:262)
	at org.eclipse.jetty.client.transport.internal.HttpSenderOverHTTP$HeadersCallback.process(HttpSenderOverHTTP.java:206)
	at org.eclipse.jetty.io.AbstractEndPoint.write(AbstractEndPoint.java:368)
	at org.eclipse.jetty.io.WriteFlusher.write(WriteFlusher.java:254)
	at org.eclipse.jetty.io.WriteFlusher.write(WriteFlusher.java:275)
	at org.eclipse.jetty.io.WriteFlusher.flush(WriteFlusher.java:422)
	at org.eclipse.jetty.io.SocketChannelEndPoint.flush(SocketChannelEndPoint.java:118)
Caused by: org.eclipse.jetty.io.EofException
	at java.base/java.lang.Thread.run(Thread.java:1575)
	...
	at io.trino.plugin.httpquery.HttpEventListener.lambda$attemptToSend$0(HttpEventListener.java:160)
	...
java.io.UncheckedIOException: Failed communicating with server: http://localhost:8000/query-event/query-completed

Thanks in advance!