flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents
Date Wed, 08 Feb 2017 13:13:41 GMT

    [ 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)

Mime
View raw message