transfer写m3db出错时打印metric信息帮助定位 (#615)
* m3db writetagged应该并发做,不然会导致transfer rpc变慢 * go func指针传参问题 * 新增k8s-mon三个大盘文件 * 新增k8s-mon三个大盘文件 * 修改k8s-mon三个大盘文件 * transfer写m3db出错时打印metric信息帮助定位
This commit is contained in:
parent
7bb93e8351
commit
dec9097ce7
src/modules/transfer/backend/m3db
|
@ -115,7 +115,12 @@ func (p *Client) Push2Queue(items []*dataobj.MetricValue) {
|
||||||
xtime.Second,
|
xtime.Second,
|
||||||
nil)
|
nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Errorf("unable to writeTagged: %s", err)
|
logger.Errorf("[endpoint:%s][metrics_name:%s][metrics_ts:%d][metrics_detail:%+v]unable to writeTagged: %s",
|
||||||
|
dm.Endpoint,
|
||||||
|
dm.Metric,
|
||||||
|
dm.Timestamp,
|
||||||
|
dm,
|
||||||
|
err)
|
||||||
atomic.AddInt32(&errCnt, 1)
|
atomic.AddInt32(&errCnt, 1)
|
||||||
}
|
}
|
||||||
wg.Done()
|
wg.Done()
|
||||||
|
|
Loading…
Reference in New Issue