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

[ISSUE #5091] [Store-A] Speed up Broker initialization by concurrently loading ConsumeQueue #5093

Merged
merged 2 commits into from Sep 20, 2022

Conversation

lizhimins
Copy link
Member

No description provided.

@lizhimins lizhimins changed the title [ISSUE #5091] [store-A] Speed up startup by concurrently loading ConsumeQueue during Broker initialization [ISSUE #5091] [Store-A] Speed up startup by concurrently loading ConsumeQueue during Broker initialization Sep 16, 2022
@lizhimins lizhimins changed the title [ISSUE #5091] [Store-A] Speed up startup by concurrently loading ConsumeQueue during Broker initialization [ISSUE #5091] [Store-A] Speed up Broker initialization by concurrently loading ConsumeQueue Sep 16, 2022
@codecov-commenter
Copy link

codecov-commenter commented Sep 16, 2022

Codecov Report

Merging #5093 (1ec50df) into develop (6efbe68) will increase coverage by 0.16%.
The diff coverage is 37.83%.

@@              Coverage Diff              @@
##             develop    #5093      +/-   ##
=============================================
+ Coverage      43.16%   43.32%   +0.16%     
- Complexity      7759     7802      +43     
=============================================
  Files            995      996       +1     
  Lines          69170    69289     +119     
  Branches        9154     9165      +11     
=============================================
+ Hits           29855    30018     +163     
+ Misses         35562    35508      -54     
- Partials        3753     3763      +10     
Impacted Files Coverage Δ
...n/java/org/apache/rocketmq/store/ConsumeQueue.java 68.49% <ø> (ø)
...apache/rocketmq/store/queue/ConsumeQueueStore.java 47.10% <13.95%> (-6.32%) ⬇️
.../java/org/apache/rocketmq/common/BrokerConfig.java 28.21% <25.00%> (-0.06%) ⬇️
...org/apache/rocketmq/store/DefaultMessageStore.java 53.57% <86.95%> (+0.17%) ⬆️
...mq/store/ha/autoswitch/AutoSwitchHAConnection.java 70.16% <0.00%> (-0.81%) ⬇️
.../main/java/org/apache/rocketmq/common/UtilAll.java 37.78% <0.00%> (-0.50%) ⬇️
...q/controller/impl/manager/ReplicasInfoManager.java 62.21% <0.00%> (-0.39%) ⬇️
...main/java/org/apache/rocketmq/store/CommitLog.java 68.57% <0.00%> (-0.19%) ⬇️
...va/org/apache/rocketmq/store/FlushDiskWatcher.java 81.25% <0.00%> (ø)
...a/org/apache/rocketmq/store/StoreStatsService.java 39.77% <0.00%> (ø)
... and 12 more

📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more

@lizhimins lizhimins mentioned this pull request Sep 16, 2022
3 tasks
ShannonDing
ShannonDing previously approved these changes Sep 16, 2022
long recoverCqStart = System.currentTimeMillis();
long maxPhyOffsetOfConsumeQueue = this.recoverConsumeQueue();
long recoverCqEnd = System.currentTimeMillis();
private boolean recover(final boolean lastExitOK, final boolean recoverConcurrently) {
Copy link
Contributor

Choose a reason for hiding this comment

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

How about keeping the original function signature? We can also get the brokerConfig in the recover function.

Copy link
Member Author

Choose a reason for hiding this comment

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

ok, I will fix it

…g ConsumeQueue during Broker initialization
@lizhimins lizhimins merged commit b7bec23 into apache:develop Sep 20, 2022
drpmma pushed a commit that referenced this pull request Feb 21, 2023
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.

None yet

6 participants