[
https://issues.apache.org/jira/browse/CASSANDRA-17199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703305#comment-17703305
]
David Capwell commented on CASSANDRA-17199:
-------------------------------------------
test refactor shows that
org.apache.cassandra.distributed.test.streaming.StreamFailureLogsFailureDueToSessionTimeoutTest
is likely the cause making things flakey. I see that the test times out after
a few minutes (should take 30s) and
{code}
junit.framework.AssertionFailedError: [node1 expected 1 element but was not
true]
Expected size:<1> but was:<0> in:
<[]>
at
org.apache.cassandra.distributed.test.streaming.AbstractStreamFailureLogs.searchForLog(AbstractStreamFailureLogs.java:132)
at
org.apache.cassandra.distributed.test.streaming.AbstractStreamFailureLogs.streamTimeoutTest(AbstractStreamFailureLogs.java:103)
at
org.apache.cassandra.distributed.test.streaming.StreamFailureLogsFailureDueToSessionTimeoutTest.failureDueToSessionTimeout(StreamFailureLogsFailureDueToSessionTimeoutTest.java:30)
{code}
Merge was called off
> Provide summary of failed SessionInfo's in StreamResultFuture
> -------------------------------------------------------------
>
> Key: CASSANDRA-17199
> URL: https://issues.apache.org/jira/browse/CASSANDRA-17199
> Project: Cassandra
> Issue Type: Improvement
> Components: Observability/Logging
> Reporter: Brendan Cicchi
> Assignee: Natnael Adere
> Priority: Normal
> Labels: AdventCalendar2021, lhf
> Fix For: 5.x
>
>
> Currently, we warn about the presence of one or more failed sessions existing
> in the final state and then an operator/user traces back through the logs to
> find any failed streams for troubleshooting.
> {code:java}
> private synchronized void maybeComplete()
> {
> if (finishedAllSessions())
> {
> StreamState finalState = getCurrentState();
> if (finalState.hasFailedSession())
> {
> logger.warn("[Stream #{}] Stream failed", planId);
> tryFailure(new StreamException(finalState, "Stream failed"));
> }
> else
> {
> logger.info("[Stream #{}] All sessions completed", planId);
> trySuccess(finalState);
> }
> }
> } {code}
> It would be helpful to log out a summary of the SessionInfo for each failed
> session since that should be accessible via the StreamState.
>
> This can be especially helpful for longer streaming operations like bootstrap
> where the failure could have been a long time back and all recent streams
> leading up to the warning actually are successful.
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
