harrylee2015 opened a new issue, #1213:
URL: https://github.com/apache/rocketmq-client-go/issues/1213
`==================
WARNING: DATA RACE
Write at 0x00c000f9a0f8 by goroutine 106:
github.com/emirpasic/gods/trees/redblacktree.(*Tree).Put()
/home/harry/go/pkg/mod/github.com/emirpasic/[email protected]/trees/redblacktree/redblacktree.go:102
+0x2a9
github.com/emirpasic/gods/maps/treemap.(*Map).Put()
/home/harry/go/pkg/mod/github.com/emirpasic/[email protected]/maps/treemap/treemap.go:49
+0x2d2
github.com/apache/rocketmq-client-go/v2/consumer.(*processQueue).putMessage()
/home/harry/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/process_queue.go:116
+0x214
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).pullMessage()
/home/harry/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:878
+0xed4
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).Start.func1.1.1()
/home/harry/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:175
+0x38
Previous read at 0x00c000f9a0f8 by goroutine 107:
github.com/emirpasic/gods/trees/redblacktree.(*Tree).Empty()
/home/harry/go/pkg/mod/github.com/emirpasic/[email protected]/trees/redblacktree/redblacktree.go:150
+0x94
github.com/emirpasic/gods/maps/treemap.(*Map).Empty()
/home/harry/go/pkg/mod/github.com/emirpasic/[email protected]/maps/treemap/treemap.go:67
+0x73
github.com/apache/rocketmq-client-go/v2/consumer.(*processQueue).takeMessages()
/home/harry/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/process_queue.go:313
+0x1a
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).consumeMessageOrderly()
/home/harry/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:1260
+0x984
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).consumeMessageOrderly-fm()
<autogenerated>:1 +0x47
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).pullMessage.func1()
/home/harry/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:642
+0xcb
github.com/apache/rocketmq-client-go/v2/primitive.WithRecover()
/home/harry/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:100
+0x41
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).pullMessage.gowrap1()
/home/harry/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:633
+0x33
Goroutine 106 (running) created at:
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).Start.func1.1()
/home/harry/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:174
+0x3a
Goroutine 107 (running) created at:
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).pullMessage()
/home/harry/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:633
+0x270
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).Start.func1.1.1()
/home/harry/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:175
+0x38
==================
`
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
