-
Notifications
You must be signed in to change notification settings - Fork 25k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Http stream activity tracker and exceptions handling #119564
Http stream activity tracker and exceptions handling #119564
Conversation
Pinging @elastic/es-distributed-coordination (Team:Distributed Coordination) |
Hi @mhl-b, I've created a changelog YAML for you. |
@@ -594,7 +594,7 @@ record Ctx(String testName, String nodeName, Bootstrap clientBootstrap, Channel | |||
@Override | |||
public void close() throws Exception { | |||
safeGet(clientChannel.close()); | |||
safeGet(clientBootstrap.config().group().shutdownGracefully()); | |||
safeGet(clientBootstrap.config().group().shutdownGracefully(0, 0, TimeUnit.SECONDS)); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
A speedup for integ test suite.
...ort-netty4/src/test/java/org/elasticsearch/http/netty4/Netty4HttpRequestBodyStreamTests.java
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM with 1 minor query
Thanks Nick! |
Pulling larger PR apart #117787.
Add HTTP body stream activity tracker when chunk is buffered. Also catch all (Throwable) exceptions when running ChunkConsumer in the channel event-loop. Some exceptions, for example OOM graceful shutdown, can slip through and never terminate stream and channel, making it hanging indefinitely. This causes issues during shutdown.