[
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 <[email protected]>
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)