Listrecords= tabHotelMapper.getHotelList(); System.out.println("酒店数据"+records); //将数据保存带es中 //1 给es中建立索引 product 建立好映射关系 //2 保存数据到es中 BulkRequest bulkRequest = new BulkRequest(); for (TabHotel skuEsModel : records) { //放到哪个索引? IndexRequest indexRequest = new IndexRequest("travel_hotel"); indexRequest.id(skuEsModel.getId()); String jsonString = JSON.toJSONString(skuEsModel); indexRequest.source(jsonString, XContentType.JSON); bulkRequest.add(indexRequest); } System.out.println("酒店数据ser"+bulkRequest); //执行 BulkResponse bulk = restHighLevelClient.bulk(bulkRequest, ElasticSearchConfig.COMMON_OPTIONS); //TODO 如果批量错误 boolean b = bulk.hasFailures(); List collect = Arrays.stream(bulk.getItems()).map(item -> { return item.getId(); }).collect(Collectors.toList()); log.info("酒店信息上传完成:{},返回数据:{}", collect, bulk.toString()); System.out.println(b); }
在elasticsearch 的config/elasticsearch.yml 下 添加 cluster.initial_master_nodes: ["127.0.0.1:9200"] 后重新启动,问题解决。



