Closed
Description
Bug Report
Please answer these questions before submitting your issue. Thanks!
- What did you do? If possible, provide a recipe for reproducing the error.
Owner exits unexpectedly due to emit checkpoint failure.
[2021/05/31 11:55:02.228 +00:00] [WARN] [server.go:188] ["run owner failed"] [error="[CDC:ErrKafkaSendMessage]kafka: Failed to deliver 1 messages."] [errorVerbose="[CDC:ErrKafkaSendMessage]kafka: Failed to deliver 1 messages.
github.com/pingcap/errors.AddStack
github.com/pingcap/errors@v0.11.5-0.20201126102027-b0a155152ca3/errors.go:174
github.com/pingcap/errors.(*Error).GenWithStackByCause
github.com/pingcap/errors@v0.11.5-0.20201126102027-b0a155152ca3/normalize.go:279
github.com/pingcap/ticdc/pkg/errors.WrapError
github.com/pingcap/ticdc@/pkg/errors/helper.go:28
github.com/pingcap/ticdc/cdc/sink/producer/kafka.(*kafkaSaramaProducer).SyncBroadcastMessage
github.com/pingcap/ticdc@/cdc/sink/producer/kafka/kafka.go:142
github.com/pingcap/ticdc/cdc/sink.(*mqSink).writeToProducer
github.com/pingcap/ticdc@/cdc/sink/mq.go:381
github.com/pingcap/ticdc/cdc/sink.(*mqSink).EmitCheckpointTs
github.com/pingcap/ticdc@/cdc/sink/mq.go:234
github.com/pingcap/ticdc/cdc.(*changeFeed).calcResolvedTs
github.com/pingcap/ticdc@/cdc/changefeed.go:939
github.com/pingcap/ticdc/cdc.(*Owner).calcResolvedTs
github.com/pingcap/ticdc@/cdc/owner.go:800
github.com/pingcap/ticdc/cdc.(*Owner).run
github.com/pingcap/ticdc@/cdc/owner.go:1334
github.com/pingcap/ticdc/cdc.(*Owner).Run
github.com/pingcap/ticdc@/cdc/owner.go:1204
github.com/pingcap/ticdc/cdc.(*Server).campaignOwnerLoop
github.com/pingcap/ticdc@/cdc/server.go:172
github.com/pingcap/ticdc/cdc.(*Server).run.func1
github.com/pingcap/ticdc@/cdc/server.go:255
golang.org/x/sync/errgroup.(*Group).Go.func1
golang.org/x/sync@v0.0.0-20201020160332-67f06af15bc9/errgroup/errgroup.go:57
runtime.goexit
runtime/asm_amd64.s:1357"]
- What did you expect to see?
TiCDC owner should not stop.
- What did you see instead?
TiCDC owner stops.
- Versions of the cluster
v5.0.1
Activity