Francis Fernandes created APEXCORE-596:
------------------------------------------
Summary: Committed method on operators not called when stream
locality is THREAD_LOCAL
Key: APEXCORE-596
URL: https://issues.apache.org/jira/browse/APEXCORE-596
Project: Apache Apex Core
Issue Type: Bug
Affects Versions: 3.5.0
Reporter: Francis Fernandes
Assignee: Francis Fernandes
When the locality of the stream connecting the two operators is
Locality.THREAD_LOCAL, the committed method is not called for some operators.
These operators implement the Operator.CheckpointListener. e.g.
AbstractFileOutputOperator
For thread local during activate we do not set the thread in the node's context
Because the thread is not set, we skip this operator in the
processHeartBeatResponse and the committed is not called
{code}
if (thread == null || !thread.isAlive()) {
continue;
}
{code}
We need this condition for invalid operators (operator failures) in case of
other localities.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
