[ 
https://issues.apache.org/jira/browse/APEXMALHAR-2269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pramod Immaneni resolved APEXMALHAR-2269.
-----------------------------------------
    Resolution: REMIND

For idempotency the failureHandling() method that processes the file later 
cannot be used. Currently, the error is being propagated which will result in 
the operator being restarted and the file being tried again. Improvements can 
be made in future to do inline retries at the same time when there are failures 
till some maximum number of retries before failing. 

> AbstractFileInputOperator: During replay, IO errors not handled
> ---------------------------------------------------------------
>
>                 Key: APEXMALHAR-2269
>                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2269
>             Project: Apache Apex Malhar
>          Issue Type: Bug
>            Reporter: Munagala V. Ramanath
>            Assignee: Matt Zhang
>
> In AbstractFileInputOperator, during replay(), if any IOExceptions occur, they
> are not handled gracefully -- the code simply throws a RuntimeException.
> Code similar to the behavior of emitTuples() needs to be added where
> the falureHandling() method is called.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to