Skip to content

Commit 7b6075b

Browse files
author
Ansj
committed
解决第一次join group不加入的bug
1 parent 7379c4a commit 7b6075b

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/main/java/org/nlpcn/jcoder/service/SharedSpaceService.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -563,9 +563,8 @@ public List<Different> joinCluster(Group group) throws IOException {
563563
if (zkDao.getZk().checkExists().forPath(GROUP_PATH + "/" + groupName) == null) {
564564
addGroup2Cluster(groupName, tasks, fileInfos);
565565
diffs = Collections.emptyList();
566-
} else {
567-
diffs = diffGroup(groupName, tasks, (ArrayList<FileInfo>) fileInfos);
568566
}
567+
diffs = diffGroup(groupName, tasks, (ArrayList<FileInfo>) fileInfos);
569568
} catch (Exception e) {
570569
e.printStackTrace();
571570
} finally {

0 commit comments

Comments
 (0)