[
https://issues.apache.org/jira/browse/CASSANDRA-13905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186026#comment-16186026
]
Ariel Weisberg commented on CASSANDRA-13905:
--------------------------------------------
+1 to the fix.
If you wanted to stick with the Streamisms you could do Collectors.toList()
after the map and then wait on futures for that. Collectors are the don't be
lazy step in streams. Although if you aren't being lazy I'm not sure the syntax
for streams is really all that much clearer.
> Correctly close netty channels when a stream session ends
> ---------------------------------------------------------
>
> Key: CASSANDRA-13905
> URL: https://issues.apache.org/jira/browse/CASSANDRA-13905
> Project: Cassandra
> Issue Type: Bug
> Components: Streaming and Messaging
> Reporter: Jason Brown
> Assignee: Jason Brown
> Fix For: 4.x
>
>
> Netty channels in stream sessions were not being closed correctly. TL;DR I
> was using a lambda that was not executing as it is lazily evaluated. This was
> causing a {{RejectedExecutionException}} at the end of some streaming-related
> dtests
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
