Skip to content
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

ISPN-15239 HotRod client repeatedly retries iteration operation again… #11422

Merged
merged 1 commit into from Oct 24, 2023

Conversation

jabolina
Copy link
Member

…st failed server after removal from topology

https://issues.redhat.com/browse/ISPN-15239

Looking at the logs, the iteration operation starts and calculates the segment owners, and then the topology updates. So, I updated the exception handling part.

@jabolina jabolina added the 14.0.x Annotate a PR with this label if you want it to be backported to the 14.0.x branch label Oct 24, 2023
@@ -112,7 +113,7 @@ protected long handleNextResponse(IterationNextResponse<K, E> nextResponse, Map.

@Override
protected void handleThrowableInResponse(Throwable t, Map.Entry<SocketAddress, IntSet> target) {
if (t instanceof TransportException || t instanceof RemoteIllegalLifecycleStateException) {
if (t instanceof TransportException || t instanceof RemoteIllegalLifecycleStateException || t instanceof ConnectException) {
Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Wondering if it needs all of:

if (cause instanceof RemoteIllegalLifecycleStateException
|| cause instanceof IOException
|| cause instanceof TransportException
|| cause instanceof RejectedExecutionException) {

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hrmm, only ConnectException would be better if it is suitable.

@@ -112,7 +113,7 @@ protected long handleNextResponse(IterationNextResponse<K, E> nextResponse, Map.

@Override
protected void handleThrowableInResponse(Throwable t, Map.Entry<SocketAddress, IntSet> target) {
if (t instanceof TransportException || t instanceof RemoteIllegalLifecycleStateException) {
if (t instanceof TransportException || t instanceof RemoteIllegalLifecycleStateException || t instanceof ConnectException) {
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hrmm, only ConnectException would be better if it is suitable.

@@ -112,7 +113,7 @@ protected long handleNextResponse(IterationNextResponse<K, E> nextResponse, Map.

@Override
protected void handleThrowableInResponse(Throwable t, Map.Entry<SocketAddress, IntSet> target) {
if (t instanceof TransportException || t instanceof RemoteIllegalLifecycleStateException) {
if (t instanceof TransportException || t instanceof RemoteIllegalLifecycleStateException || t instanceof ConnectException) {
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We also need to add this to the hotrod module as well.

…st failed server after removal from topology
@jabolina
Copy link
Member Author

Updated the hotrod module.

@wburns wburns merged commit 9199e2b into infinispan:main Oct 24, 2023
3 of 4 checks passed
@wburns
Copy link
Member

wburns commented Oct 24, 2023

Integrated into main, thanks @jabolina !

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
14.0.x Annotate a PR with this label if you want it to be backported to the 14.0.x branch
Projects
None yet
2 participants