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