【 TiKV 使用环境】生产环境
【 TiKV 版本】
使用tiup部署的 raw tikv
Cluster type: tidb
Cluster version: v5.0.1
Deploy user: tikv
【遇到的问题】
raw batch put
// BatchPut stores key-value pairs to TiKV.
func (c *Client) BatchPut(ctx context.Context, keys, values [][]byte, ttls []uint64) error {
start := time.Now()
defer func() {
metrics.RawkvCmdHistogramWithBatchPut.Observe(time.Since(start).Seconds())
}()
查看tikv.log
[2022/06/01 12:21:50.570 +00:00] [ERROR] [kv.rs:887] ["batch_commands error"] [err=Codec(WireError(UnexpectedWireType(WireTypeLengthDelimited)))]
[2022/06/01 12:21:51.045 +00:00] [ERROR] [kv.rs:887] ["batch_commands error"] [err=Codec(WireError(UnexpectedWireType(WireTypeLengthDelimited)))]
[2022/06/01 12:21:51.523 +00:00] [ERROR] [kv.rs:887] ["batch_commands error"] [err=Codec(WireError(UnexpectedWireType(WireTypeLengthDelimited)))]
[2022/06/01 12:21:52.010 +00:00] [ERROR] [kv.rs:887] ["batch_commands error"] [err=Codec(WireError(UnexpectedWireType(WireTypeLengthDelimited)))]
[2022/06/01 12:21:52.424 +00:00] [ERROR] [kv.rs:887] ["batch_commands error"] [err=Codec(WireError(UnexpectedWireType(WireTypeLengthDelimited)))]
请提供各个组件的 version 信息，如 cdc/tikv，可通过执行 cdc version/tikv-server --version 获取。