WARNING: DATA RACE
Write at 0x00c00193d498 by goroutine 1987:
github.com/pingcap/ticdc/logservice/logpuller.(*SubscriptionClient).Run()
/root/workspace/repo/ticdc/logservice/logpuller/subscription_client.go:333 +0x111
github.com/pingcap/ticdc/logservice/logpuller.(*LogPuller).Run.func3()
/root/workspace/repo/ticdc/logservice/logpuller/log_puller.go:160 +0x84
golang.org/x/sync/errgroup.(*Group).Go.func1()
/root/.gvm/pkgsets/go1.21.7/global/pkg/mod/golang.org/x/sync@v0.8.0/errgroup/errgroup.go:78 +0x91
Previous write at 0x00c00193d498 by goroutine 1984:
github.com/pingcap/ticdc/logservice/logpuller.(*SubscriptionClient).Run()
/root/workspace/repo/ticdc/logservice/logpuller/subscription_client.go:333 +0x111
github.com/pingcap/ticdc/logservice/logpuller.(*LogPuller).Run.func3()
/root/workspace/repo/ticdc/logservice/logpuller/log_puller.go:160 +0x84
golang.org/x/sync/errgroup.(*Group).Go.func1()
/root/.gvm/pkgsets/go1.21.7/global/pkg/mod/golang.org/x/sync@v0.8.0/errgroup/errgroup.go:78 +0x91
Goroutine 1987 (running) created at:
golang.org/x/sync/errgroup.(*Group).Go()
/root/.gvm/pkgsets/go1.21.7/global/pkg/mod/golang.org/x/sync@v0.8.0/errgroup/errgroup.go:75 +0x124
github.com/pingcap/ticdc/logservice/logpuller.(*LogPuller).Run()
/root/workspace/repo/ticdc/logservice/logpuller/log_puller.go:160 +0x495
github.com/pingcap/ticdc/logservice/eventstore.(*eventStore).Run.func3()
/root/workspace/repo/ticdc/logservice/eventstore/event_store.go:425 +0x84
golang.org/x/sync/errgroup.(*Group).Go.func1()
/root/.gvm/pkgsets/go1.21.7/global/pkg/mod/golang.org/x/sync@v0.8.0/errgroup/errgroup.go:78 +0x91
Goroutine 1984 (running) created at:
golang.org/x/sync/errgroup.(*Group).Go()
/root/.gvm/pkgsets/go1.21.7/global/pkg/mod/golang.org/x/sync@v0.8.0/errgroup/errgroup.go:75 +0x124
github.com/pingcap/ticdc/logservice/logpuller.(*LogPuller).Run()
/root/workspace/repo/ticdc/logservice/logpuller/log_puller.go:160 +0x495
github.com/pingcap/ticdc/logservice/eventstore.(*eventStore).Run.func2()
/root/workspace/repo/ticdc/logservice/eventstore/event_store.go:421 +0x84
golang.org/x/sync/errgroup.(*Group).Go.func1()
/root/.gvm/pkgsets/go1.21.7/global/pkg/mod/golang.org/x/sync@v0.8.0/errgroup/errgroup.go:78 +0x91
