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 2021/06/29 02:09:07 UTC
[GitHub] [rocketmq-client-go] weichangdong opened a new issue #690: SendAsync send big message panic
weichangdong opened a new issue #690:
URL: https://github.com/apache/rocketmq-client-go/issues/690
go mod use this version
```
github.com/apache/rocketmq-client-go/v2 v2.1.0
```
```
err = rocketmqclient.RocketmqProducer.SendAsync(context.Background(),
func(ctx context.Context, result *primitive.SendResult, e error) {
if e != nil || result == nil || (result != nil && result.Status != primitive.SendOK) {
logs.Error("SendAsync SendAsync message error: ", e, " result:", result, " msgLen:", len(string(msgByte)), " ctime:", ctime, " relatedUid:", relatedUid, " relatedTid:", relatedTid)
if result != nil {
logs.Error("result:", result.String())
}
err = e
sendOk = false
} else {
sendOk = true
}
}, rocketmqMsg)
```
the log output
```
SendAsync SendAsync message error: <nil> result: %!v(PANIC=String method: runtime error: invalid memory address or nil pointer dereference) msgLen: 788741 ctime: 1624901003080 relatedUid: radtatmbcpg5cemoqjs8t324l0 relatedTid:
```
maxMessageSize=65536
Although our setting is small, it should not panic
--
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.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] wenfengwang commented on issue #690: SendAsync send big message panic
Posted by GitBox <gi...@apache.org>.
wenfengwang commented on issue #690:
URL: https://github.com/apache/rocketmq-client-go/issues/690#issuecomment-881327771
it is not a bug, i will check it
--
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.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] wenfengwang commented on issue #690: SendAsync send big message panic
Posted by GitBox <gi...@apache.org>.
wenfengwang commented on issue #690:
URL: https://github.com/apache/rocketmq-client-go/issues/690#issuecomment-884831955
the issue was fixed at https://github.com/apache/rocketmq-client-go/pull/702
--
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.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] weichangdong commented on issue #690: SendAsync send big message panic
Posted by GitBox <gi...@apache.org>.
weichangdong commented on issue #690:
URL: https://github.com/apache/rocketmq-client-go/issues/690#issuecomment-879845185
```
SendAsync SendAsync message error: request timeout result: <nil> msgLen: 764 ctime: 1626257106588 relatedUid: ctx: context.Background.WithDeadline(2021-07-14 15:35:09.592028007 +0530 IST m=+3764.379185364 [2.999812347s]) ctxErr: context canceled
```
使用了master的代码,panic没了,但是一直报错,但是消息并没有丢. 我觉得主要应该是最新的代码 加了
-- 之前的
ctx, _ = context.WithTimeout(ctx, 3*time.Second)
-- 最新的
var cancel context.CancelFunc
ctx, cancel = context.WithTimeout(ctx, 3*time.Second)
defer cancel()
这是bug么?
--
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.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] weichangdong removed a comment on issue #690: SendAsync send big message panic
Posted by GitBox <gi...@apache.org>.
weichangdong removed a comment on issue #690:
URL: https://github.com/apache/rocketmq-client-go/issues/690#issuecomment-879659944
--
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.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] weichangdong commented on issue #690: SendAsync send big message panic
Posted by GitBox <gi...@apache.org>.
weichangdong commented on issue #690:
URL: https://github.com/apache/rocketmq-client-go/issues/690#issuecomment-879659944
This problem did not appear after we changed the maximum message Settings,
maxMessageSize=4194304
but for now there is Panic using the current master code(Fork the code to tag myself )
I suspect RocketMQ is under stress at that point, Grafana's monitoring shows that the Broker's TPS has grown to 100 to 150, but no RocketMQ error log is available
--
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.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] wenfengwang closed issue #690: SendAsync send big message panic
Posted by GitBox <gi...@apache.org>.
wenfengwang closed issue #690:
URL: https://github.com/apache/rocketmq-client-go/issues/690
--
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.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] weichangdong edited a comment on issue #690: SendAsync send big message panic
Posted by GitBox <gi...@apache.org>.
weichangdong edited a comment on issue #690:
URL: https://github.com/apache/rocketmq-client-go/issues/690#issuecomment-879845185
```
SendAsync SendAsync message error: request timeout result: <nil> msgLen: 764 ctime: 1626257106588 relatedUid: ctx: context.Background.WithDeadline(2021-07-14 15:35:09.592028007 +0530 IST m=+3764.379185364 [2.999812347s]) ctxErr: context canceled
```
使用了master的代码,panic没了,但是一直报错,但是消息并没有丢. 我觉得主要应该是最新的代码 加了
```
-- 之前的
ctx, _ = context.WithTimeout(ctx, 3*time.Second)
-- 最新的
var cancel context.CancelFunc
ctx, cancel = context.WithTimeout(ctx, 3*time.Second)
defer cancel()
```
这是bug么?
--
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.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] weichangdong commented on issue #690: SendAsync send big message panic
Posted by GitBox <gi...@apache.org>.
weichangdong commented on issue #690:
URL: https://github.com/apache/rocketmq-client-go/issues/690#issuecomment-879660384
SendAsync SendAsync message error: <nil> result: %!v(PANIC=String method: runtime error: invalid memory address or nil pointer dereference) msgLen: 1077 ctime: 1626150327634
--
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.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] weichangdong edited a comment on issue #690: SendAsync send big message panic
Posted by GitBox <gi...@apache.org>.
weichangdong edited a comment on issue #690:
URL: https://github.com/apache/rocketmq-client-go/issues/690#issuecomment-879660384
```
SendAsync SendAsync message error: <nil> result: %!v(PANIC=String method: runtime error: invalid memory address or nil pointer dereference) msgLen: 1077 ctime: 1626150327634
```
--
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.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org