[
https://issues.apache.org/jira/browse/APEXCORE-654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942152#comment-15942152
]
ASF GitHub Bot commented on APEXCORE-654:
-----------------------------------------
GitHub user bhupeshchawda opened a pull request:
https://github.com/apache/apex-core/pull/497
[REVIEW-ONLY] APEXCORE-654 fix update recovery window when delay part of
group
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bhupeshchawda/apex-core
APEXCORE-654-recovery-window-delay
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/apex-core/pull/497.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 #497
----
commit 57b094418552b4474c064a8a317e9bed7dc0d473
Author: bhupeshchawda <[email protected]>
Date: 2017-03-26T05:27:51Z
APEXCORE-654 fix update recovery window when delay part of group
----
> Recovery window is not updated when Delay Operator is used along with
> Partitioned Operators
> -------------------------------------------------------------------------------------------
>
> Key: APEXCORE-654
> URL: https://issues.apache.org/jira/browse/APEXCORE-654
> Project: Apache Apex Core
> Issue Type: Bug
> Affects Versions: 3.5.0
> Environment: Hadoop 2.7.2
> Apache Apex 3.5.0
> Apache Apex Malhar 3.6.0
> Reporter: Ambarish Pande
> Assignee: Bhupesh Chawda
> Labels: DelayOperator
>
> Checkpointing is not happening when DefaultDelayOperator is used in a DAG in
> which some upstream operators are Partitioned.
> When used without partitioning, I can see the operators being check-pointed
> properly.
> Here is the link of the App source code and also the built apa file.
> https://github.com/ambarishpande/delay-operator-test
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
