[
https://issues.apache.org/jira/browse/APEXCORE-654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ambarish Pande updated APEXCORE-654:
------------------------------------
Attachment: (was: Delay test no checkpointing.png)
> No Checkpointing is done 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
> Labels: DelayOperator
>
> Checkpointing is not happening when DefaultDelayOperator is used in a DAG in
> which some upstream operators are Partitioned. I have attached screenshots of
> the application DAG and also stats showing that the checkpointing is not
> being done.
> 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)
