《公司商业秘密保护和员工保密意识培养》--闻方老师

Nginx 反向代理之 http_proxy_module 模块

  返回  

flink写es报分片不足

2021/7/21 11:01:18 浏览:

flink写es报分片不足:
ERROR org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase [] - Failed Elasticsearch item request: ElasticsearchException[Elasticsearch exception [type=illegal_argument_exception, reason=Validation Failed: 1: this action would add [15] total shards, but this cluster currently has [2986]/[3000] maximum shards open;]]
org.elasticsearch.ElasticsearchException: Elasticsearch exception [type=illegal_argument_exception, reason=Validation Failed: 1: this action would add [15] total shards, but this cluster currently has [2986]/[3000]maximum shards open;]


原理参考 https://studygolang.com/articles/25396


解决:删除过期不用的索引:
curl -XDELETE -u elastic:elasticpasswd http://localhost:9200/index_name


单个索引删除
curl -XDELETE -u elastic:elasticpasswd http://localhost:9200/index_name
多个索引删除,用逗号分开
curl -XDELETE -u elastic:elasticpasswd http://localhost:9200/index_name1,index_name2
多个索引模糊匹配删除
curl -XDELETE -u elastic:elasticpasswd http://localhost:9200/index_name1*

联系我们

如果您对我们的服务有兴趣,请及时和我们联系!

服务热线:18288888888
座机:18288888888
传真:
邮箱:888888@qq.com
地址:郑州市文化路红专路93号