[
https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15857967#comment-15857967
]
ASF GitHub Bot commented on FLINK-5353:
---------------------------------------
Github user static-max commented on the issue:
https://github.com/apache/flink/pull/3246
Looks great!
One note: In your example ExampleActionRequestFailureHandler you have to
unwrap the Exception, as it is typical looks like:
`RemoteTransportException[[Richard
Rider][127.0.0.1:9301][indices:data/write/bulk[s]]]; nested:
RemoteTransportException[[Richard
Rider][127.0.0.1:9301][indices:data/write/bulk[s][p]]]; nested:
EsRejectedExecutionException[rejected execution of
org.elasticsearch.transport.TransportService$4@e5c47a1 on
EsThreadPoolExecutor[bulk, queue capacity = 1,
org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor@7e2d5cc5[Running,
pool size = 8, active threads = 8, queued tasks = 1, completed tasks = 119]]];`
In my implementation I use Apache commons:
`
ExceptionUtils.indexOfThrowable(throwable,
EsRejectedExecutionException.class) >= 0
`
> Elasticsearch Sink loses well-formed documents when there are malformed
> documents
> ---------------------------------------------------------------------------------
>
> Key: FLINK-5353
> URL: https://issues.apache.org/jira/browse/FLINK-5353
> Project: Flink
> Issue Type: Bug
> Components: Streaming Connectors
> Affects Versions: 1.1.3
> Reporter: Flavio Pompermaier
> Assignee: Tzu-Li (Gordon) Tai
>
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
