datasync / yoho-datasync-fullsync · Commits

Go to a project

Authored by 张帅
Commit 07d14f5178f0c319335b1f3153cab72d35d4c35a 1 parent f0422449

update

Inline Side-by-side
Showing 1 changed file with 1 additions and 1 deletions
@@ -91,7 +91,7 @@ public class UserInfoDataSyncServiceImpl { @@ -91,7 +91,7 @@ public class UserInfoDataSyncServiceImpl {
91 // 批量增加 91 // 批量增加
92 BulkRequest bulkAddRequest = new BulkRequest(); 92 BulkRequest bulkAddRequest = new BulkRequest();
93 for (UserInfo info : userInfoList) { 93 for (UserInfo info : userInfoList) {
94 - IndexRequest indexRequest = new IndexRequest("grass", "userInfo2", String.valueOf(info.getYoho_uid())); 94 + IndexRequest indexRequest = new IndexRequest("grass", "userInfo", String.valueOf(info.getYoho_uid()));
95 indexRequest.source(JSON.toJSONString(info), XContentType.JSON); 95 indexRequest.source(JSON.toJSONString(info), XContentType.JSON);
96 bulkAddRequest.add(indexRequest); 96 bulkAddRequest.add(indexRequest);
97 } 97 }