?????? flink????????????????????????????kafka??????sink es??????????????????????????kafka??????????????????????????????????BulkFlushMaxActions??5000????????50????????????
2021-09-05 10:28:24,737 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Sink: ???????? (19/21)' did not react to cancelling signal for 30 seconds, but is stuck in method: org.elasticsearch.action.bulk.BulkProcessor.internalAdd(BulkProcessor.java:286) org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:271) org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:267) org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:253) org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6BulkProcessorIndexer.add(Elasticsearch6BulkProcessorIndexer.java:72) ideal.mousika.job.operator.sink.ElasticsearchSinkNode$1.process(ElasticsearchSinkNode.java:145) ideal.mousika.job.operator.sink.ElasticsearchSinkNode$1.process(ElasticsearchSinkNode.java:86) org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.invoke(ElasticsearchSinkBase.java:310) org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:56) org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:161) org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.processElement(StreamTaskNetworkInput.java:178) org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.emitNext(StreamTaskNetworkInput.java:153) org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:67) org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:351) org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$169/636333370.runDefaultAction(Unknown Source) org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxStep(MailboxProcessor.java:191) org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:181) org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:566) org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:536) org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721) org.apache.flink.runtime.taskmanager.Task.run(Task.java:546) java.lang.Thread.run(Thread.java:745)
