Skip to content

Conversation

horizonzy
Copy link
Member

What is the purpose of the change

Fix-#2535
Use one variable value to log info when eventQueue's size more than 10000.

@coveralls
Copy link

coveralls commented Dec 30, 2020

Coverage Status

Coverage decreased (-0.01%) to 51.928% when pulling bf9a474 on horizonzy:fix-2535 into 0239421 on apache:develop.

@codecov-io
Copy link

Codecov Report

Merging #2536 (d10b15c) into develop (0239421) will decrease coverage by 0.02%.
The diff coverage is 0.00%.

Impacted file tree graph

@@              Coverage Diff              @@
##             develop    #2536      +/-   ##
=============================================
- Coverage      45.97%   45.94%   -0.03%     
+ Complexity      4318     4316       -2     
=============================================
  Files            547      547              
  Lines          36236    36237       +1     
  Branches        4808     4808              
=============================================
- Hits           16658    16648      -10     
- Misses         17491    17503      +12     
+ Partials        2087     2086       -1     
Impacted Files Coverage Δ Complexity Δ
...rocketmq/remoting/netty/NettyRemotingAbstract.java 50.73% <0.00%> (-0.19%) 22.00 <0.00> (ø)
...ain/java/org/apache/rocketmq/test/util/MQWait.java 43.24% <0.00%> (-5.41%) 3.00% <0.00%> (ø%)
...ketmq/client/impl/consumer/PullMessageService.java 71.11% <0.00%> (-4.45%) 8.00% <0.00%> (-1.00%)
...ketmq/common/protocol/body/ConsumerConnection.java 95.83% <0.00%> (-4.17%) 13.00% <0.00%> (-1.00%)
...org/apache/rocketmq/common/stats/StatsItemSet.java 41.79% <0.00%> (-1.50%) 16.00% <0.00%> (-1.00%)
...che/rocketmq/namesrv/kvconfig/KVConfigManager.java 59.18% <0.00%> (-1.03%) 11.00% <0.00%> (-1.00%)
...he/rocketmq/client/impl/consumer/ProcessQueue.java 60.93% <0.00%> (-0.94%) 32.00% <0.00%> (ø%)
...e/rocketmq/client/impl/consumer/RebalanceImpl.java 45.81% <0.00%> (-0.80%) 32.00% <0.00%> (-1.00%)
.../apache/rocketmq/logging/inner/LoggingBuilder.java 63.60% <0.00%> (-0.32%) 3.00% <0.00%> (ø%)
...ava/org/apache/rocketmq/filter/util/BitsArray.java 59.82% <0.00%> (ø) 30.00% <0.00%> (ø%)
... and 4 more

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 0239421...d10b15c. Read the comment docs.

this.eventQueue.add(event);
} else {
log.warn("event queue size[{}] enough, so drop this event {}", this.eventQueue.size(), event.toString());
log.warn("event queue size[{}] enough, so drop this event {}", currentSize, event.toString());
Copy link
Contributor

Choose a reason for hiding this comment

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

IMO, print currentSize and maxSize will be better.

Copy link
Member Author

Choose a reason for hiding this comment

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

agree

Copy link
Member Author

Choose a reason for hiding this comment

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

please take a look the new msg.

@yuz10 yuz10 merged commit 1635856 into apache:develop Dec 10, 2021
devfat pushed a commit to devfat/rocketmq that referenced this pull request Mar 3, 2022
* [ISSUE apache#2535] Use one variable value to log info when eventQueue's size more than 10000.

* add the queue limit value when evenQueue size is enough.
GenerousMan pushed a commit to GenerousMan/rocketmq that referenced this pull request Aug 12, 2022
* [ISSUE apache#2535] Use one variable value to log info when eventQueue's size more than 10000.

* add the queue limit value when evenQueue size is enough.
carlvine500 pushed a commit to carlvine500/rocketmq-apache that referenced this pull request Sep 10, 2024
* [ISSUE apache#2535] Use one variable value to log info when eventQueue's size more than 10000.

* add the queue limit value when evenQueue size is enough.
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.

5 participants