[
https://issues.apache.org/jira/browse/APEXCORE-810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16443772#comment-16443772
]
ASF GitHub Bot commented on APEXCORE-810:
-----------------------------------------
PramodSSImmaneni opened a new pull request #595: APEXCORE-810 Removing channel
correctly from the set while scanning through it
URL: https://github.com/apache/apex-core/pull/595
@vrozov please see
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Concurrent modification exception during connection cleanup in buffer server
> ----------------------------------------------------------------------------
>
> Key: APEXCORE-810
> URL: https://issues.apache.org/jira/browse/APEXCORE-810
> Project: Apache Apex Core
> Issue Type: Bug
> Reporter: Pramod Immaneni
> Assignee: Pramod Immaneni
> Priority: Minor
>
> ERROR com.datatorrent.bufferserver.server.Server: Buffer server
> Server@56cfec7c\{address=/0:0:0:0:0:0:0:0:45081} failed to tear down
> subscriber
> Subscriber@2ff22212{ln=LogicalNode@36d87f9eidentifier=tcp://xxxxxx:45081/2.output.1,
> upstream=2.output.1, group=rand_console/3.input, partitions=[],
> iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6caeed6a{da=com.datatorrent.bufferserver.internal.DataList$Block@506501e4{identifier=2.output.1,
> data=16777216, readingOffset=0, writingOffset=1822,
> starting_window=59dc9c3000000001, ending_window=59dc9c3000000055, refCount=2,
> uniqueIdentifier=0, next=null,
> future=null}}}}.java.util.ConcurrentModificationException
> at java.util.HashMap$HashIterator.nextEntry(HashMap.java:922)
> at java.util.HashMap$KeyIterator.next(HashMap.java:956)
> at
> com.datatorrent.bufferserver.internal.LogicalNode.removeChannel(LogicalNode.java:118)
> at com.datatorrent.bufferserver.server.Server$3.run(Server.java:410)
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask.run(FutureTask.java:262)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
