You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2020/11/19 06:45:37 UTC
[GitHub] [rocketmq] tangtangsara opened a new issue #2439: TransientStorePool only remain 0 sheets
tangtangsara opened a new issue #2439:
URL: https://github.com/apache/rocketmq/issues/2439
**BUG REPORT**
version 4.7.1
config file :
maxMessageSize=8388608
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
aclEnable=false
transientStorePoolEnable=false
transientStorePoolSize=1
sendMessageThreadPoolNums=16
useReentrantLockWhenPutMessage=true
in store.log on server :
2020-11-19 10:11:43 WARN AllocateMappedFileService - Use default implementation.
2020-11-19 10:11:43 WARN AllocateMappedFileService - TransientStorePool only remain 0 sheets.
and same time , clients error message
[REJECTREQUEST]system busy, start flow control for a while
can not set transientStorePoolSize=1 ? must be greate than 1 ?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] tangtangsara edited a comment on issue #2439: TransientStorePool only remain 0 sheets
Posted by GitBox <gi...@apache.org>.
tangtangsara edited a comment on issue #2439:
URL: https://github.com/apache/rocketmq/issues/2439#issuecomment-731260567
> You are not using transientStorePool！**Check config careful.**
> Ref bellow code:
>
> ```
> if (messageStore.getMessageStoreConfig().isTransientStorePoolEnable()) {
> try {
> } catch (RuntimeException e) {
> log.warn("Use default implementation.");
> }
> }
> ```
>
> Only transientStorePoolEnable=true，log will print `Use default implementation`.
I make a mistake . I copy config file after the error happen , and then disable transientStorePoolEnable.
the config is transientStorePoolEnable=true when error happens
@gaoyf
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] RongtongJin closed issue #2439: TransientStorePool only remain 0 sheets
Posted by GitBox <gi...@apache.org>.
RongtongJin closed issue #2439:
URL: https://github.com/apache/rocketmq/issues/2439
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] gaoyf commented on issue #2439: TransientStorePool only remain 0 sheets
Posted by GitBox <gi...@apache.org>.
gaoyf commented on issue #2439:
URL: https://github.com/apache/rocketmq/issues/2439#issuecomment-730945393
You are not using transientStorePool！**Check config careful.**
Ref bellow code:
```
if (messageStore.getMessageStoreConfig().isTransientStorePoolEnable()) {
try {
} catch (RuntimeException e) {
log.warn("Use default implementation.");
}
}
```
Only transientStorePoolEnable=true，log will print `Use default implementation`.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] gaoyf commented on issue #2439: TransientStorePool only remain 0 sheets
Posted by GitBox <gi...@apache.org>.
gaoyf commented on issue #2439:
URL: https://github.com/apache/rocketmq/issues/2439#issuecomment-731888072
如果你不想用transientStorePool机制，禁止就行了，它不会消耗内存。
如果想用，就不要设为1，因为每个`MappedFile`持有一个从transientStorePool借出大小为1G堆外内存。
如果transientStorePoolSize设为1，那么pool里只有一个1G的堆外内存，在`MappedFile`写满切换时势必受到影响。
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] tangtangsara commented on issue #2439: TransientStorePool only remain 0 sheets
Posted by GitBox <gi...@apache.org>.
tangtangsara commented on issue #2439:
URL: https://github.com/apache/rocketmq/issues/2439#issuecomment-731263575
> default value of transientStorePoolSize is 5, default size value is 1g
i know default value of transientStorePoolSize is 5, and default size is 1g.
i want to determine set to 1 Is it allowed?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] maixiaohai commented on issue #2439: TransientStorePool only remain 0 sheets
Posted by GitBox <gi...@apache.org>.
maixiaohai commented on issue #2439:
URL: https://github.com/apache/rocketmq/issues/2439#issuecomment-730398116
default value of transientStorePoolSize is 5, default size value is 1g
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] tangtangsara commented on issue #2439: TransientStorePool only remain 0 sheets
Posted by GitBox <gi...@apache.org>.
tangtangsara commented on issue #2439:
URL: https://github.com/apache/rocketmq/issues/2439#issuecomment-731260567
> You are not using transientStorePool！**Check config careful.**
> Ref bellow code:
>
> ```
> if (messageStore.getMessageStoreConfig().isTransientStorePoolEnable()) {
> try {
> } catch (RuntimeException e) {
> log.warn("Use default implementation.");
> }
> }
> ```
>
> Only transientStorePoolEnable=true，log will print `Use default implementation`.
I make a mistake . I copy setting after the error happen , and then disable transientStorePoolEnable.
the config is transientStorePoolEnable=true when error happens
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] tangtangsara edited a comment on issue #2439: TransientStorePool only remain 0 sheets
Posted by GitBox <gi...@apache.org>.
tangtangsara edited a comment on issue #2439:
URL: https://github.com/apache/rocketmq/issues/2439#issuecomment-731260567
> You are not using transientStorePool！**Check config careful.**
> Ref bellow code:
>
> ```
> if (messageStore.getMessageStoreConfig().isTransientStorePoolEnable()) {
> try {
> } catch (RuntimeException e) {
> log.warn("Use default implementation.");
> }
> }
> ```
>
> Only transientStorePoolEnable=true，log will print `Use default implementation`.
I make a mistake . I copy setting after the error happen , and then disable transientStorePoolEnable.
the config is transientStorePoolEnable=true when error happens
@gaoyf
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org