dcapwell commented on code in PR #3379:
URL: https://github.com/apache/cassandra/pull/3379#discussion_r1645034786
##########
test/distributed/org/apache/cassandra/distributed/test/accord/AccordBootstrapTest.java:
##########
@@ -267,7 +267,7 @@ public void bootstrapTest() throws Throwable
StreamListener.listener.forSession(session -> {
Assert.assertEquals(node3Addr,
session.peer.getAddress());
Assert.assertEquals(0, session.getNumRequests());
- Assert.assertTrue(session.getNumTransfers() > 0);
+ Assert.assertTrue(session.getNumKeyspaceTransfers() >
0);
Review Comment:
I punted on trying to fix the test... we actually don't stream anything....
##########
test/unit/org/apache/cassandra/repair/LocalSyncTaskTest.java:
##########
@@ -171,7 +171,7 @@ private static void assertNumInOut(StreamPlan plan, int
expectedIncoming, int ex
StreamCoordinator coordinator = plan.getCoordinator();
StreamSession session =
Iterables.getOnlyElement(coordinator.getAllStreamSessions());
assertEquals(expectedIncoming, session.getNumRequests());
- assertEquals(expectedOutgoing, session.getNumTransfers());
+ assertEquals(expectedOutgoing, session.getNumKeyspaceTransfers());
Review Comment:
I punted on trying to fix the test... we actually don't stream anything....
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
