You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by "Sandesh (JIRA)" <ji...@apache.org> on 2017/02/14 23:21:41 UTC
[jira] [Created] (APEXCORE-647) Positive reference count exception
during Purge
Sandesh created APEXCORE-647:
--------------------------------
Summary: Positive reference count exception during Purge
Key: APEXCORE-647
URL: https://issues.apache.org/jira/browse/APEXCORE-647
Project: Apache Apex Core
Issue Type: Bug
Components: Buffer Server
Reporter: Sandesh
Steps to reproduce
1. Use AvroInput reader with a big schema (100+ fields)
2. Kill the input operator
During next purge below exception happens
java.lang.IllegalStateException: Discarded block com.datatorrent.bufferserver.internal.DataList$Block@74e7e699{identifier=6.output.2, data=67108864, readingOffset=0, writingOffset=67108864, starting_window=13a, ending_window=13b, refCount=1, uniqueIdentifier=0, next=6.output.2, future=Done} has positive reference count!
at com.datatorrent.bufferserver.internal.DataList.purge(DataList.java:199)
at com.datatorrent.bufferserver.server.Server.purge(Server.java:204)
at com.datatorrent.stram.engine.StreamingContainer.processHeartbeatResponse(StreamingContainer.java:777)
at com.datatorrent.stram.engine.StreamingContainer.heartbeatLoop(StreamingContainer.java:706)
at com.datatorrent.stram.engine.StreamingContainer.main(StreamingContainer.java:311)
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)