Skip to content

Commit 373deba

Browse files
authored
fix: Pass cluster id tranforming drop task to drop job request (#42531)
Related to #42530 The cluster id is missing when drop worker drop causing redoing task on report duplicated task error. Signed-off-by: Congqi Xia <[email protected]>
1 parent 0567f51 commit 373deba

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

internal/datanode/services.go

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -812,9 +812,14 @@ func (node *DataNode) DropTask(ctx context.Context, request *workerpb.DropTaskRe
812812
if err != nil {
813813
return merr.Status(err), nil
814814
}
815+
clusterID, err := properties.GetClusterID()
816+
if err != nil {
817+
return merr.Status(err), nil
818+
}
815819
return node.DropJobsV2(ctx, &workerpb.DropJobsV2Request{
816-
TaskIDs: []int64{taskID},
817-
JobType: jobType,
820+
ClusterID: clusterID,
821+
TaskIDs: []int64{taskID},
822+
JobType: jobType,
818823
})
819824
default:
820825
err := fmt.Errorf("unrecognized task type '%s', properties=%v", taskType, request.GetProperties())

0 commit comments

Comments
 (0)