Flink sink Elasticsearch 防止任务中断
Flink sink Elasticsearch 防止任务中断前言从半年现在从0开始搭建Flink实时计算平台，部分存储层用到了Elasticsearch，从零开始接触Flink，这半年来遇到了好多坑，由传统的开发转变成了大数据开发，Elasticsearch内含有多种熔断器，为了防止OOM。由于目前业务查询的方式会造成成本很高，（可以看一下allow_expensive_querys），某次查询可能会引起服务的熔断，这时候有可能引起实时任务 sink Elasticsearch请求也会被熔断。
