[ 
https://issues.apache.org/jira/browse/APEXMALHAR-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16041616#comment-16041616
 ] 

ASF GitHub Bot commented on APEXMALHAR-2404:
--------------------------------------------

GitHub user prasannapramod reopened a pull request:

    https://github.com/apache/apex-malhar/pull/625

    APEXMALHAR-2404  Avro file input operator should call beginWindow of 
AbstractFileInputOperator.

     @devtagare   @sandeshh please see

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/prasannapramod/apex-malhar APEXMALHAR-2404

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/apex-malhar/pull/625.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #625
    
----
commit 3fb3b4e039b2d20e68a5565edbd0a02b97e2e815
Author: Lakshmi Prasanna Velineni <laks...@datatorrent.com>
Date:   2017-05-18T22:35:09Z

    APEXMALHAR-2404 Provided fixes for kryo seralization & atleast once 
semantics for recovery.
    Added unit test case to verify atleast once semantics for recovery.

----


> Avro file input operator should call beginWindow of AbstractFileInputOperator
> -----------------------------------------------------------------------------
>
>                 Key: APEXMALHAR-2404
>                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2404
>             Project: Apache Apex Malhar
>          Issue Type: Bug
>            Reporter: Sandesh
>            Assignee: Velineni Lakshmi Prasanna
>
> Avro file input operator is atmost once as it is not calling beginWindow of 
> abstractFileInputOperator and recovery happens only in 
> AbstractFileInputOperator



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to