Ambarish Pande created APEXCORE-654:
---------------------------------------
Summary: 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
Attachments: Delay Test DAG.png, Delay test no checkpointing.png
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)
