[jira] [Commented] (CASSANDRA-17510) Streaming sessions longer than 3 minutes fail with timeout

2022-04-01 Thread Benedict Elliott Smith (Jira)


[ 
https://issues.apache.org/jira/browse/CASSANDRA-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516017#comment-17516017
 ] 

Benedict Elliott Smith commented on CASSANDRA-17510:


LGTM

> Streaming sessions longer than 3 minutes fail with timeout
> --
>
> Key: CASSANDRA-17510
> URL: https://issues.apache.org/jira/browse/CASSANDRA-17510
> Project: Cassandra
>  Issue Type: Bug
>  Components: Consistency/Streaming
>Reporter: Jon Meredith
>Assignee: Jon Meredith
>Priority: Normal
> Fix For: 4.1
>
>  Time Spent: 1h
>  Remaining Estimate: 0h
>
> Streaming sessions that take longer than 3 minutes will fail with an 
> InputTimeoutException on the streaming control channel connection.
> CASSANDRA-16927 refactored the streaming code as part of CEP-10 to clean up 
> some abstractions. As part of those changes the StreamDeserializingTask 
> (formerly StreamingInboundHandler) had a check removed that ensured data was 
> present before reading from the AsyncStreamingInputPlus used by 
> NettyStreamingChannel to pass incoming bytes to be deserialized off the main 
> Netty event loop threads. When {{reBuffer}ing from the input, 
> AsyncStreamingInputPlus times out if no data is received in three minutes.
> It is perfectly valid for no messages to be received over the control 
> connection for longer than three minutes - pre CASSANDRA-16927 just doesn’t 
> do the read until data is present, so it doesn’t hit the timeout. A possible 
> solution is to replace throwing the InputTimeoutException with a check that 
> the channel is still open and retry.
> Note this is unrelated to the streaming protocol KeepAlive removal - that had 
> a default timeout of five minutes so would not have been effective anyway.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

-
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org



[jira] [Commented] (CASSANDRA-17510) Streaming sessions longer than 3 minutes fail with timeout

2022-03-31 Thread Caleb Rackliffe (Jira)


[ 
https://issues.apache.org/jira/browse/CASSANDRA-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515684#comment-17515684
 ] 

Caleb Rackliffe commented on CASSANDRA-17510:
-

+1

 

(Left a couple more minor comments in the PR)

> Streaming sessions longer than 3 minutes fail with timeout
> --
>
> Key: CASSANDRA-17510
> URL: https://issues.apache.org/jira/browse/CASSANDRA-17510
> Project: Cassandra
>  Issue Type: Bug
>  Components: Consistency/Streaming
>Reporter: Jon Meredith
>Assignee: Jon Meredith
>Priority: Normal
> Fix For: 4.1
>
>  Time Spent: 50m
>  Remaining Estimate: 0h
>
> Streaming sessions that take longer than 3 minutes will fail with an 
> InputTimeoutException on the streaming control channel connection.
> CASSANDRA-16927 refactored the streaming code as part of CEP-10 to clean up 
> some abstractions. As part of those changes the StreamDeserializingTask 
> (formerly StreamingInboundHandler) had a check removed that ensured data was 
> present before reading from the AsyncStreamingInputPlus used by 
> NettyStreamingChannel to pass incoming bytes to be deserialized off the main 
> Netty event loop threads. When {{reBuffer}ing from the input, 
> AsyncStreamingInputPlus times out if no data is received in three minutes.
> It is perfectly valid for no messages to be received over the control 
> connection for longer than three minutes - pre CASSANDRA-16927 just doesn’t 
> do the read until data is present, so it doesn’t hit the timeout. A possible 
> solution is to replace throwing the InputTimeoutException with a check that 
> the channel is still open and retry.
> Note this is unrelated to the streaming protocol KeepAlive removal - that had 
> a default timeout of five minutes so would not have been effective anyway.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

-
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org



[jira] [Commented] (CASSANDRA-17510) Streaming sessions longer than 3 minutes fail with timeout

2022-03-31 Thread Jon Meredith (Jira)


[ 
https://issues.apache.org/jira/browse/CASSANDRA-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515422#comment-17515422
 ] 

Jon Meredith commented on CASSANDRA-17510:
--

[PR|https://github.com/jonmeredith/cassandra/pull/new/C17510-streaming-three-min-timeout]
 
[Branch|https://github.com/jonmeredith/cassandra/tree/C17510-streaming-three-min-timeout]
 
[CircleCI|https://app.circleci.com/pipelines/github/jonmeredith/cassandra?branch=C17510-streaming-three-min-timeout=all]

> Streaming sessions longer than 3 minutes fail with timeout
> --
>
> Key: CASSANDRA-17510
> URL: https://issues.apache.org/jira/browse/CASSANDRA-17510
> Project: Cassandra
>  Issue Type: Bug
>  Components: Consistency/Streaming
>Reporter: Jon Meredith
>Assignee: Jon Meredith
>Priority: Normal
> Fix For: 4.1
>
>
> Streaming sessions that take longer than 3 minutes will fail with an 
> InputTimeoutException on the streaming control channel connection.
> CASSANDRA-16927 refactored the streaming code as part of CEP-10 to clean up 
> some abstractions. As part of those changes the StreamDeserializingTask 
> (formerly StreamingInboundHandler) had a check removed that ensured data was 
> present before reading from the AsyncStreamingInputPlus used by 
> NettyStreamingChannel to pass incoming bytes to be deserialized off the main 
> Netty event loop threads. When {{reBuffer}ing from the input, 
> AsyncStreamingInputPlus times out if no data is received in three minutes.
> It is perfectly valid for no messages to be received over the control 
> connection for longer than three minutes - pre CASSANDRA-16927 just doesn’t 
> do the read until data is present, so it doesn’t hit the timeout. A possible 
> solution is to replace throwing the InputTimeoutException with a check that 
> the channel is still open and retry.
> Note this is unrelated to the streaming protocol KeepAlive removal - that had 
> a default timeout of five minutes so would not have been effective anyway.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

-
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org