8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 03:42:07 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

[Bugfix]修复迁移任务状态不一致问题(#815)

Browse Source
This commit is contained in:
wyb
2022-12-08 17:02:37 +08:00
committed by EricZeng
parent 5cad7b4106
commit c4fb18a73c
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java
View File

@@ -508,8 +508,9 @@ public class ReassignJobServiceImpl implements ReassignJobService {
}
});
if (!topicPartitions.isEmpty()){
return opPartitionService.preferredReplicaElection(jobPO.getClusterPhyId(), topicPartitions);
//无论优先副本选举是否成功，都返回成功，以保证job的数据更新
if (!topicPartitions.isEmpty()) {
opPartitionService.preferredReplicaElection(jobPO.getClusterPhyId(), topicPartitions);
}
return Result.buildSuc();