Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Done
-
None
-
None
-
None
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():
if (!partialWindowTuples.isEmpty() && windowId > windowDataManager.getLargestCompletedWindow()) { throw new RuntimeException("Violates Exactly once. Not all the tuples received after operator reset."); }
Note:
It is failing because of the bug in the WindowDataManager,
https://issues.apache.org/jira/browse/APEXMALHAR-2422
Attachments
Issue Links
- relates to
-
APEXMALHAR-2422 WindowDataManager not recovering as expected on HDFS
- Closed