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)