-
Type:
Bug
-
Resolution: Fixed
-
Priority:
Major - P3
-
Affects Version/s: None
-
Component/s: Operations
-
None
-
None
-
None
-
None
-
None
-
None
-
None
-
None
See jeff.yemin's analysis in https://jira.mongodb.org/browse/JAVA-2858
There may be a similar problem in ChangeStreamCusor.cs
Relevant snippet from ChangeStreamCursor.cs:
public bool MoveNext(CancellationToken cancellationToken = default(CancellationToken))
{
bool hasMore;
try
{
hasMore = _cursor.MoveNext(cancellationToken);
}
catch (Exception ex)
{
if (RetryabilityHelper.IsResumableChangeStreamException(ex))
{
_cursor = _changeStreamOperation.Resume(_binding, _resumeToken, cancellationToken);
hasMore = _cursor.MoveNext(cancellationToken);
}
else
{
throw;
}
}
ProcessBatch(hasMore);
return hasMore;
}
- related to
-
JAVA-2858 ChangeStream cursor raises a MongoSocketReadException when there is no event since last replica set election
-
- Closed
-