es bulk java_es v6.8.3 bulk 异常
项目启动正常,使用kibana连接es正常,数据入库会时会报如下异常
org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: [{#transport#-1}{_X6NAOs9Q_GFms7gODeelQ}{192.168.138.165}{192.168.138.165:9300}]
at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:352)
at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:248)
at org.elasticsearch.client.transport.TransportProxyClient.execute(TransportProxyClient.java:60)
at org.elasticsearch.client.transport.TransportClient.doExecute(TransportClient.java:388)
at org.elasticsearch.client.support.AbstractClient.execute(AbstractClient.java:403)
at org.elasticsearch.client.support.AbstractClient.bulk(AbstractClient.java:482)
at org.elasticsearch.action.bulk.Retry$RetryHandler.execute(Retry.java:232)
at org.elasticsearch.action.bulk.Retry.withBackoff(Retry.java:59)
at org.elasticsearch.action.bulk.BulkRequestHandler.execute(BulkRequestHandler.java:62)
at org.elasticsearch.action.bulk.BulkProcessor.execute(BulkProcessor.java:381)
at org.elasticsearch.action.bulk.BulkProcessor.access$300(BulkProcessor.java:52)
at org.elasticsearch.action.bulk.BulkProcessor$Flush.run(BulkProcessor.java:415)
at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:681)
at org.elasticsearch.threadpool.Scheduler$ReschedulingRunnable.doRun(Scheduler.java:247)
at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:751)
at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
es bulk java_es v6.8.3 bulk 异常相关推荐
- es bulk java_ES 操作之批量写-BulkProcessor 原理浅析
最近对线上业务进行重构,涉及到ES同步这一块,在重构过程中,为了ES 写入 性能考虑,大量的采取了 bulk的方式,来保证整体的一个同步速率,针对BulkProcessor 来深入一下,了解下 是如何 ...
- bulk插入 es_elasticsearch的helpers.bulk和es_client.bulk的用法
from elasticsearch import Elasticsearch import datetime es_client = Elasticsearch(["127.0.0.1:9 ...
- elasticsearch使用bulk实现批量操作
本篇文章提供ES原生批量操作语法及使用bulk批量操作文档.文章依旧提供语法,具体实现大家根据语法,在对应处进行替换即可 一.原生批量获取文档 1.获取指定文档值(1) 语法: GET /_mget ...
- 【Elastischearch】Elastischearch bulk 请求源码
1.概述 转载 https://blog.csdn.net/sinat_33760891/article/details/74175981 想基于和这个看看es 7.8的源码,结果相差比较大,没看完 ...
- 初识ElasticSearch(5) -批量操作之bulk | 条件查询 | 其它查询
1. bulk: 1.1. bulk语法: 1.2. bulk行为-增删改: 2. bulk-index批量插入: 3. bulk-update批量修改: 4. bulk-delete批量删除: 5. ...
- bulk Java提交数据,Elasticsearch 之(47) Java API 基于bulk实现多4S店销售数据批量上传...
PUT /car_shop/sales/1 { "brand": "宝马", "name": "宝马320", &quo ...
- navicat使用查询向表中插入一行记录_SQL--每日一解------Bulk Insert 快速插入
SQL INSERT INTO 语句 INSERT INTO 语句用于向表中插入新记录. SQL INSERT INTO 语法 INSERT INTO 语句可以有两种编写形式. ① 第一种形式无需指定 ...
- Elasticsearch java api(五) Bulk批量索引
一.Bulk API 使用bulk命令时,REST API以_bulk结尾,批量操作写在json文件中,官网给出的语法格式: action_and_meta_data\n optional_sourc ...
- SqlBulkCopy只支持SQL Server? EF Core实现支持多数据库类型的Bulk Copy
前言 Microsoft SQL Server包含一个名为bcp的命令行实用工具,可以将较大文件快速大容量复制到SQL Server数据库的表或视图中,这种方法被称为Bulk Copy(批量复制). ...
最新文章
- 【深度学习】基于Pytorch的softmax回归问题辨析和应用(二)
- [ NOI 2002 ] Robot
- VSCode打造成为开发神器-插件篇
- ruby elixir_如何使用Elixir和Phoenix快速入门构建CRUD REST API
- 初学者css常见问题_5分钟内学习CSS-初学者教程
- Ubuntu,kubuntu与xubuntu的差别 Ubuntu各版本主要差异
- python求解LeetCode习题Maximum Gap
- 微信小程序云开发教程-JavaScript入门(1)-学习环境、函数、调试
- PDF怎么转换成图片?来看这两种好用的方法
- 攻防世界-MISC-摩斯电码
- vue基础模板代码块设置
- 到底linux下的管道是什么?
- 分布式之分布式事务、分布式锁、分布式Session
- 计算机无法登录到网络,电脑无法连接到这个网络是什么原因
- Java项目:SSM设备台账管理系统
- linux下运行讯飞语音云的测试程序
- GPS车辆定位,汽车实时在线防止公车私用!
- 简单的下载excel模板
- CSAPP: bomb lab
- 支持windows vista和7 32/64位操作系统的区域转码软件