-
Notifications
You must be signed in to change notification settings - Fork 13.9k
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
MINOR: Ignore test_broker_type_bounce_at_start system test #5055
MINOR: Ignore test_broker_type_bounce_at_start system test #5055
Conversation
@@ -171,6 +172,9 @@ public void makeReady(final Map<String, InternalTopicConfig> topics) { | |||
*/ | |||
// visible for testing | |||
protected Map<String, Integer> getNumPartitions(final Set<String> topics) { | |||
log.debug("Trying to check if topics {} have been created with expected number of partitions.", topics); | |||
|
|||
// TODO: KAFKA-6928. should not need retries in the outer caller as it will be retried internally in admin client |
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.
Let's avoid TODOs in the code. We can point to the relevant part of the code in the JIRA.
@@ -577,7 +577,9 @@ final void fail(long now, Throwable throwable) { | |||
// this RPC. That is why 'tries' is not incremented. | |||
if ((throwable instanceof UnsupportedVersionException) && | |||
handleUnsupportedVersionException((UnsupportedVersionException) throwable)) { | |||
log.trace("{} attempting protocol downgrade.", this); | |||
if (log.isDebugEnabled()) { |
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.
There's no need for this conditional, right?
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 bit unfortunate that this comment was ignored, it caused a checkstyle error with the new checkstyle:
test_broker_type_bounce_at_start tries to validate that when the controller is down, the streams client will always fail trying to create the topic; with the current behavior of admin client it is actually not always true: the actual behavior depends on the admin client internals as well as when the controller becomes unavailable during the leader assign partitions phase. I'd suggest at least ignore this test for now until the admin client has more stable (personally I'd even suggest removing this test as its coverage benefits is smaller than its introduced issues to me). Also adding a few more log4j entries as a result of investigating this issue. Reviewers: Matthias J. Sax <[email protected]>
test_broker_type_bounce_at_start tries to validate that when the controller is down, the streams client will always fail trying to create the topic; with the current behavior of admin client it is actually not always true: the actual behavior depends on the admin client internals as well as when the controller becomes unavailable during the leader assign partitions phase. I'd suggest at least ignore this test for now until the admin client has more stable (personally I'd even suggest removing this test as its coverage benefits is smaller than its introduced issues to me).
Also adding a few more log4j entries as a result of investigating this issue.
Committer Checklist (excluded from commit message)