未验证 提交 e0baf153 编写于 作者: M MrPresent-Han 提交者: GitHub

[skip e2e] Improve a commment for initial pr (#20287)

Signed-off-by: NMrPresent-Han <jamesharden11122@gmail.com>
Signed-off-by: NMrPresent-Han <jamesharden11122@gmail.com>
上级 5143df18
......@@ -108,8 +108,9 @@ func (fm *flowgraphManager) getChannel(segID UniqueID) (Channel, error) {
return nil, fmt.Errorf("cannot find segment %d in all flowgraphs", segID)
}
// resendTT loops through flow graphs, looks for segments that are not flushed, and sends them to that flow graph's
// `resendTTCh` channel so stats of these segments will be resent.
// resendTT loops through flow graphs, looks for segments that are not flushed,
// and sends them to that flow graph's `resendTTCh` channel so stats of
// these segments will be resent.
func (fm *flowgraphManager) resendTT() []UniqueID {
var unFlushedSegments []UniqueID
fm.flowgraphs.Range(func(key, value interface{}) bool {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册