[
https://issues.apache.org/jira/browse/NIFI-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Handermann updated NIFI-14170:
------------------------------------
Fix Version/s: 2.6.0
Resolution: Fixed
Status: Resolved (was: Patch Available)
> ListenWebSocketProcessor doesn't work:
> "org.eclipse.jetty.ee10.servlet.ServletApiRequest.getRequest()" is null
> --------------------------------------------------------------------------------------------------------------
>
> Key: NIFI-14170
> URL: https://issues.apache.org/jira/browse/NIFI-14170
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Affects Versions: 2.1.0
> Reporter: Andrei Koiro
> Assignee: RAVINARAYAN SINGH
> Priority: Major
> Fix For: 2.6.0
>
> Attachments: NiFi_Flow.json, Screenshot 2025-01-17 at 00.35.06.png
>
> Time Spent: 1h 20m
> Remaining Estimate: 0h
>
>
> {code:java}
> 2025-01-16 23:58:02,114 WARN [qtp297136886-98]
> o.a.n.w.jetty.RoutingWebSocketListener Unhandled Error: Endpoint
> org.apache.nifi.websocket.jetty.RoutingWebSocketListener :
> org.eclipse.jetty.websocket.api.exceptions.CloseException:
> org.eclipse.jetty.websocket.core.exception.WebSocketException:
> RoutingWebSocketListener OPEN method error: Cannot invoke
> "org.eclipse.jetty.server.Request.isSecure()" because the return value of
> "org.eclipse.jetty.ee10.servlet.ServletApiRequest.getRequest()" is null {code}
> ListenWebSocketProcessor doesn't work
> It happens because our code tries to call
> org.eclipse.jetty.ee10.servlet.ServletApiRequest.getRequest() after the
> current ServletChannel already was "recycle"d
>
> org.apache.nifi.processors.websocket.ListenWebSocket
> {code:java}
> protected String getTransitUri(final WebSocketSessionInfo sessionInfo) {
> final InetSocketAddress localAddress = sessionInfo.getLocalAddress();
> return (sessionInfo.isSecure() ? "wss:" : "ws:")
> + localAddress.getHostName() + ":" + localAddress.getPort() +
> endpointId;
> }
> {code}
> org.eclipse.jetty.ee10.servlet.ServletChannel
> {code:java}
> void recycle(Throwable x)
> {
> // _httpInput must be recycled before _state.
> _httpInput.recycle();
> _httpOutput.recycle();
> _state.recycle();
> _servletContextRequest = null;
> _request = null;
> _response = null;
> _callback = null;
> }
> {code}
> org.eclipse.jetty.ee10.servlet.ServletContextHandler:1170
> {code:java}
> Request.addCompletionListener(servletContextRequest, servletChannel::recycle);
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
