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

[FLINK-3893] improve LeaderChangeStateCleanupTest #2009

Closed
wants to merge 2 commits into from

Conversation

mxm
Copy link
Contributor

@mxm mxm commented May 19, 2016

Fixes discovered in the course of #1978.

@@ -61,8 +61,6 @@ public void stop() throws Exception {
public void notifyListener(String address, UUID leaderSessionID) {
if (listener != null) {
listener.notifyLeaderAddress(address, leaderSessionID);
} else {
throw new IllegalStateException("The retrieval service has not been started properly.");
Copy link
Contributor

@zentol zentol May 19, 2016

Choose a reason for hiding this comment

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

the commit name doesn't seem to properly reflect the change made; it should be "don't fail if retrieval service has not been started"

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Good catch! Fixing that.

@asfgit asfgit closed this in 9b8de6a May 20, 2016
mbode pushed a commit to mbode/flink that referenced this pull request May 27, 2016
- increase timeout for task managers to be registered
- don't fail if leader retrieval service has not been started yet

This closes apache#2009
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants