diff --git a/src/main/java/com/bfd/crawl/handlerdata/service/ElasticSearchService.java b/src/main/java/com/bfd/crawl/handlerdata/service/ElasticSearchService.java index 991a168..a286608 100644 --- a/src/main/java/com/bfd/crawl/handlerdata/service/ElasticSearchService.java +++ b/src/main/java/com/bfd/crawl/handlerdata/service/ElasticSearchService.java @@ -49,7 +49,7 @@ public class ElasticSearchService { String host = (String) admin.get("host"); String port = (String) admin.get("port"); String requestUrl = "http://"; - requestUrl = requestUrl.concat("172.26.250.44").concat(":").concat("9200").concat("/"); + requestUrl = requestUrl.concat("8.152.196.157").concat(":").concat("19200").concat("/"); String scoreUrl = requestUrl.concat("_search/scroll"); requestUrl = requestUrl.concat("cl_special_1.0_").concat(indexs).concat("/_search?scroll=5m"); int index = 1; @@ -86,7 +86,7 @@ public class ElasticSearchService { Request firstRequest = new Request.Builder() .url(requestUrl) .method("POST", body) - .addHeader("Authorization", "Basic ZWxhc3RpYzpiYWlmZW5kaWFuMTIz") + .addHeader("Authorization", "Basic ZWxhc3RpYzpid0AyMDI1") .addHeader("Content-Type", "application/json") .build(); String firstResultString = null; @@ -136,7 +136,7 @@ public class ElasticSearchService { RequestBody bodyScroll = RequestBody.create(mediaTypeScroll, JSON.toJSONString(newQlMap)); Request scrollRequest = new Request.Builder() .url(scoreUrl) - .method("POST", bodyScroll).addHeader("Authorization", "Basic ZWxhc3RpYzpiYWlmZW5kaWFuMTIz") + .method("POST", bodyScroll).addHeader("Authorization", "Basic ZWxhc3RpYzpid0AyMDI1") .addHeader("Content-Type", "application/json") .build(); String scrollResultString = null; @@ -227,7 +227,7 @@ public class ElasticSearchService { Request firstRequest = new Request.Builder() .url(requestUrl) .method("POST", body) - .addHeader("Authorization", "Basic ZWxhc3RpYzpiYWlmZW5kaWFuMTIz") + .addHeader("Authorization", "Basic ZWxhc3RpYzpid0AyMDI1") .addHeader("Content-Type", "application/json") .build(); Response firstResponse = client.newCall(firstRequest).execute();