kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Rajini Sivaram (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (KAFKA-5595) Illegal state in SocketServer; attempt to send with another send in progress
Date Fri, 14 Jul 2017 19:57:00 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-5595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16087916#comment-16087916
] 

Rajini Sivaram edited comment on KAFKA-5595 at 7/14/17 7:56 PM:
----------------------------------------------------------------

Connection id contains remote port, it is currently logging processor id, hence the integer
value 7 in the logs. I have submitted a PR to fix that.

[~ijuma] Since connection id contains remote port, for the scenario you described, the port
needs to get reused. Typically that shouldn't happen while still processing requests of an
older connection using that port. In theory, I suppose it could happen if there lots of connections
being created and closed.




was (Author: rsivaram):
Connection id contains remote port, it is currently logging processor id, hence the integer
value 7 in the logs. I have submitted a PR to fix that.

[~ijuma] Since connection id contains remote port, for the scenario you described, the port
needs to get reused. Typically that shouldn't happen while still processing requests of an
older connection using that port. The channel should have been closed and removed from selector
before the new connection.



> Illegal state in SocketServer; attempt to send with another send in progress
> ----------------------------------------------------------------------------
>
>                 Key: KAFKA-5595
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5595
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Jason Gustafson
>
> I have seen this a couple times, but I'm not sure the conditions associated with it.

> {code}
> java.lang.IllegalStateException: Attempt to begin a send operation with prior send operation
still in progress.
> 	at org.apache.kafka.common.network.KafkaChannel.setSend(KafkaChannel.java:138)
> 	at org.apache.kafka.common.network.Selector.send(Selector.java:248)
> 	at kafka.network.Processor.sendResponse(SocketServer.scala:488)
> 	at kafka.network.Processor.processNewResponses(SocketServer.scala:466)
> 	at kafka.network.Processor.run(SocketServer.scala:431)
> 	at java.lang.Thread.run(Thread.java:748)
> {code}
> Prior to this event, I see a lot of this message in the logs (always for the same connection
id):
> {code}
> Attempting to send response via channel for which there is no open connection, connection
id 7
> {code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message