[
https://issues.apache.org/jira/browse/APEXMALHAR-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandesh updated APEXMALHAR-2419:
--------------------------------
Description:
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}
Note:
It is failing because of the bug in the WindowDataManager,
https://issues.apache.org/jira/browse/APEXMALHAR-2422
was:
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}
> 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
> Assignee: Sandesh
>
> 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}
> Note:
> It is failing because of the bug in the WindowDataManager,
> https://issues.apache.org/jira/browse/APEXMALHAR-2422
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
