[jira] [Created] (APEXCORE-647) Positive reference count exception during Purge

[Sandesh (JIRA)]

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)