[jira] [Commented] (APEXMALHAR-2404) Avro file input operator should call beginWindow of AbstractFileInputOperator

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

[jira] [Commented] (APEXMALHAR-2404) Avro file input operator should call beginWindow of AbstractFileInputOperator

JIRA jira@apache.org

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

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 <[hidden email]>
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.4.14#64029)
Loading...