Resolve an issue with bulk load with "DataNode abnormal"

[soothing-rain]

Resolve an issue with bulk load where segments in flow graph replica are not updated

issue: #15604

/kind enhancement

Signed-off-by: Yuchen Gao yuchen.gao@zilliz.com

[mergify]

@soothing-rain, please be sure the pr should only have one commit, check https://github.com/milvus-io/milvus/blob/master/CODE_REVIEW.md for more details.

[mergify]

@soothing-rain ut workflow job failed, comment rerun ut can trigger the job again.

[codecov]

Codecov Report

Merging #16609 (e0380cb) into master (242f08f) will increase coverage by 0.18%.
The diff coverage is 87.05%.

@@            Coverage Diff             @@
##           master   #16609      +/-   ##
==========================================
+ Coverage   80.55%   80.73%   +0.18%     
==========================================
  Files         437      437              
  Lines       68504    68989     +485     
==========================================
+ Hits        55183    55698     +515     
+ Misses      10686    10643      -43     
- Partials     2635     2648      +13     

Impacted Files	Coverage Δ
internal/datacoord/services.go	87.45% <42.85%> (-0.28%)	⬇️
internal/rootcoord/root_coord.go	77.89% <68.42%> (-0.08%)	⬇️
internal/datacoord/segment_manager.go	83.05% <85.71%> (+0.23%)	⬆️
internal/datacoord/cluster.go	95.34% <100.00%> (+0.16%)	⬆️
internal/datacoord/server.go	73.39% <100.00%> (+0.10%)	⬆️
internal/datanode/data_node.go	80.85% <100.00%> (+0.77%)	⬆️
internal/datanode/flow_graph_insert_buffer_node.go	86.66% <100.00%> (ø)
internal/util/funcutil/parallel.go	95.77% <0.00%> (-4.23%)	⬇️
internal/querynode/query_channel.go	39.74% <0.00%> (-3.85%)	⬇️
internal/proxy/plan_parser.go	81.75% <0.00%> (-1.49%)	⬇️
... and 35 more

[yhmo]

/lgtm

[mergify]

@soothing-rain E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@soothing-rain ut workflow job failed, comment rerun ut can trigger the job again.

[soothing-rain]

rerun ut

[congqixia]

/lgtm

[sre-ci-robot]

[APPROVALNOTIFIER] This PR is APPROVED

This pull-request has been approved by: congqixia, soothing-rain

The full list of commands accepted by this bot can be found here.

The pull request process is described here

Needs approval from an approver in each of these files:

• internal/datacoord/OWNERS [congqixia]
• internal/datanode/OWNERS [congqixia]
• internal/proto/OWNERS [congqixia]
• internal/rootcoord/OWNERS [congqixia]

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment