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/01/04 03:12:24 UTC
[GitHub] [rocketmq-client-go] xxd763795151 commented on issue #568: [v2.2.0] DATA RACE
xxd763795151 commented on issue #568:
URL: https://github.com/apache/rocketmq-client-go/issues/568#issuecomment-753734273
We also have a similar problem:
conditon:
* one consumer group subscribe multi topic
* message has accumulated a lot when starting the consumer client
log info:
> WARNING: DATA RACE
> Read at 0x00c0006b6a88 by goroutine 272:
> github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).pullMessage()
> /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:488 +0xac2
> github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).Start.func1.1.1()
> /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:156 +0x42
>
> Previous write at 0x00c0006b6a88 by goroutine 326:
> sync/atomic.AddInt64()
> /usr/local/go1.14.7/src/runtime/race_amd64.s:276 +0xb
> github.com/apache/rocketmq-client-go/v2/consumer.(*processQueue).removeMessage()
> /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/process_queue.go:181 +0x2c1
> github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).consumeMessageCurrently.func1()
> /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:941 +0xa35
> github.com/apache/rocketmq-client-go/v2/primitive.WithRecover()
> /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/primitive/base.go:96 +0x5a
>
> Goroutine 272 (running) created at:
> github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsu mer).Start.func1.1()
> /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:155 +0x6b
>
> Goroutine 326 (running) created at:
> github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).consumeMessageCurrently()
> /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:875 +0xe6
> github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).consumeMessageCurrently-fm()
> /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:860 +0x55
> github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).pullMessage.func1()
> /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:443 +0xbc
> github.com/apache/rocketmq-client-go/v2/primitive.WithRecover()
> /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/primitive/base.go:96 +0x5a
----------------------------------------------------------------
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