twz915 commented on PR #1081:
URL:
https://github.com/apache/rocketmq-client-go/pull/1081#issuecomment-1690916275
==================
WARNING: DATA RACE
Read at 0x00c000baa5d8 by goroutine 904:
github.com/apache/rocketmq-client-go/v2/internal.(*SubscriptionData).Clone()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/model.go:70
+0x1d4
github.com/apache/rocketmq-client-go/v2/consumer.(*defaultConsumer).SubscriptionDataList.func1()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/consumer.go:457
+0x6c
sync.(*Map).Range()
/usr/local/go/src/sync/map.go:476 +0x2d8
github.com/apache/rocketmq-client-go/v2/consumer.(*defaultConsumer).SubscriptionDataList()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/consumer.go:456
+0xf4
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).SubscriptionDataList()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:351
+0x4c
github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).UpdateTopicRouteInfo.func2()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:706
+0x90
sync.(*Map).Range()
/usr/local/go/src/sync/map.go:476 +0x2d8
github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).UpdateTopicRouteInfo()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:704
+0x3d8
github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1.2.1()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:447
+0x34
github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1.2()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:457
+0x38c
github.com/apache/rocketmq-client-go/v2/primitive.WithRecover()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:100
+0x50
github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1.7()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:444
+0x3c
Previous write at 0x00c000baa5d8 by goroutine 907:
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).messageQueueChanged()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:505
+0x30c
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).messageQueueChanged-fm()
<autogenerated>:1 +0xb8
github.com/apache/rocketmq-client-go/v2/consumer.(*defaultConsumer).doBalance.func1()
/Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]
--
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]
