Munagala V. Ramanath created APEXMALHAR-2419:
------------------------------------------------
Summary: KafkaSinglePortExactlyOnceOutputOperator fails on recovery
Key: APEXMALHAR-2419
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2419
Project: Apache Apex Malhar
Issue Type: Bug
Reporter: Munagala V. Ramanath
The KafkaSinglePortExactlyOnceOutputOperator fails on recovery with the
message: "Violates Exactly once. Not all the tuples received after operator
reset."
This is because of this check in endWindow():
{code}
if (!partialWindowTuples.isEmpty() && windowId >
windowDataManager.getLargestCompletedWindow()) {
throw new RuntimeException("Violates Exactly once. Not all the tuples
received after operator reset.");
}
{code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
