??
flinkkafka??sink
es??kafka??BulkFlushMaxActions??500050
2021-09-05 10:28:24,737 WARN
org.apache.flink.runtime.taskmanager.Task
[] - Task 'Sink: (19/21)' did
flink sink es exception，也暂时没有思路。2019-02-23 19:46:34.460 +0800 [Source:
order_label_map -> Flat Map -> Map (1/1)] WARN
[com.imdada.parse.OrderLabelParse] [AbstractParseModel.scala:20] - fail parse
json
object:{"eventType":1,"execTime":1550820023000,&quo
阿里大神，这问题无思路了。偶先。暂时不清楚会不会丢数据。从falcon对es的监控来看，es正常。2019-02-23 19:46:30.965 +0800
[Source: jd_mall_order -> Flat Map -> (Sink: Unnamed, Sink: Unnamed) (1/1)]
WARN [com.imdada.parse.PublishTimeParse] [AbstractParseModel.scala:20] - fail
parse json
es 5.x
flink bulk sink
现象：运行几秒钟后抛异常
es数据可以正确插入
这个异常导致cpu上升
Caused by: org.elasticsearch.transport.SendRequestTransportException:
[basedata03][10.10.2.15:9300][indices:data/write/bulk]
at
org.elasticsearch.transport.TransportService.sendRequestInternal(TransportService.java:531)
at
