-
Notifications
You must be signed in to change notification settings - Fork 1k
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
Fixing up cluster rejoin behavior #962
Fixing up cluster rejoin behavior #962
Conversation
if (handle.IsFaulted) | ||
{ | ||
var inner = handle.Exception.Flatten().InnerException; | ||
return (object)new Status.Failure(new InvalidAssociationException("Association failure", inner)); |
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.
Not sure if this is the right status failure
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.
That should be right
The ClusterDomainEventPublisherSpec is still failing all tests for this build. |
@Aaronontheweb After this build i'll rebase and squash |
|
||
if (alreadyMember) _log.Info("Existing member [{0}] is trying to join, ignoring", node); | ||
else if (isUnreachable) _log.Info("Unreachable member [{0}] is trying to join, ignoring", node); | ||
if (localMember != null && localMember.UniqueAddress == node) |
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.
were these just areas where we weren't totally up to date with the JVM version?
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.
yup
#918 linking issue |
_log.Info("New incarnation of existing member [{0}] is trying to join. " + | ||
"Existing will be removed from the cluster and then new member will be allowed to join.", node); | ||
if (localMember.Status != MemberStatus.Down && localMember.Status != MemberStatus.Leaving && localMember.Status != MemberStatus.Exiting) | ||
Downing(localMember.Address); |
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.
so is this where the magic happens for downing the unreachable node going forward? The "big fix" as it were?
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.
This is the big fix for #918 . This allows the node to rejoin
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.
cool - that's what I thought. Awesome - looks simple enough and explains what wasn't working well before.
Fixed rejoining node Fixed ClusterDomainEventPublisher spec
…vior Fixing up cluster rejoin behavior
Fixed rejoining node