cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ariel Weisberg (JIRA)" <>
Subject [jira] [Commented] (CASSANDRA-13905) Correctly close netty channels when a stream session ends
Date Fri, 29 Sep 2017 16:18:00 GMT


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:
>             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

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message