Skip to content

KAFKA-4222: Adjust timeout in low resource environments#2996

Closed
enothereska wants to merge 1 commit intoapache:trunkfrom
enothereska:KAFKA-4222-queryOnRebalance
Closed

KAFKA-4222: Adjust timeout in low resource environments#2996
enothereska wants to merge 1 commit intoapache:trunkfrom
enothereska:KAFKA-4222-queryOnRebalance

Conversation

@enothereska
Copy link
Copy Markdown
Contributor

No description provided.

@enothereska
Copy link
Copy Markdown
Contributor Author

This other PR is also needed of course: #2982

@asfbot
Copy link
Copy Markdown

asfbot commented May 8, 2017

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/3649/
Test PASSed (JDK 8 and Scala 2.11).

@asfbot
Copy link
Copy Markdown

asfbot commented May 8, 2017

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/kafka-pr-jdk7-scala2.10/3643/
Test PASSed (JDK 7 and Scala 2.10).

@asfbot
Copy link
Copy Markdown

asfbot commented May 8, 2017

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/3639/
Test FAILed (JDK 8 and Scala 2.12).

@mjsax
Copy link
Copy Markdown
Member

mjsax commented May 8, 2017

@enothereska Can you elaborate in this PR. With #2982 I am wondering why we need this?

@enothereska
Copy link
Copy Markdown
Contributor Author

@mjsax yes, I tested all the streams test in an ultra-low resource environment (1 wimpy core, 1GB of RAM) and even with the RocksDB fix the queryOnRebalance test would fail. Sometimes the network would appear flaky, requiring more retries (I've changed to 10). Sometimes the rebalance would take forever, requiring new timeouts.

@enothereska
Copy link
Copy Markdown
Contributor Author

cc @guozhangwang

@guozhangwang
Copy link
Copy Markdown
Contributor

@eno I'm still wondering why the rebalance could take forever, since we only have a single thread that will own all the tasks, and it has graceful shutdown / re-start so there should be no restoration at all?

@enothereska
Copy link
Copy Markdown
Contributor Author

In a low resource env, everything competes for a bit of resources, the producer thread, the main streams thread and the rebalancing. It all crawls.

@guozhangwang
Copy link
Copy Markdown
Contributor

In a low resource env, everything competes for a bit of resources, the producer thread, the main streams thread and the rebalancing. It all crawls.

@enothereska Okay, I think I'm a bit over-concerned with your description that rebalance take forever since it is only a single thread, so if it really take very long to create tasks / restore it would be a problem.

Copy link
Copy Markdown
Contributor

@guozhangwang guozhangwang left a comment

Choose a reason for hiding this comment

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

Merged to trunk.

@asfgit asfgit closed this in 5b36add May 9, 2017
@enothereska enothereska deleted the KAFKA-4222-queryOnRebalance branch May 9, 2017 16:35
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants