Details
-
Bug
-
Status: Resolved
-
Normal
-
Resolution: Fixed
-
None
-
Correctness - Test Failure
-
Normal
-
Normal
-
DTest
-
All
-
None
-
Description
In j11_dtests from CASSANDRA-19034
https://app.circleci.com/pipelines/github/mike-tr-adamson/cassandra/402/workflows/92aacb84-fd3a-48e0-9fb2-d1e2fe6fc71a/jobs/35345/tests
AssertionError: assert 'MOVED_NODE' == 'NEW_NODE' - NEW_NODE + MOVED_NODE self = <pushed_notifications_test.TestPushedNotifications object at 0x7fd28ee838d0> @pytest.mark.no_vnodes def test_move_single_node(self): """ @jira_ticket CASSANDRA-8516 Moving a token should result in MOVED_NODE notifications. """ self.cluster.populate(3).start() waiters = [NotificationWaiter(self, node, ["TOPOLOGY_CHANGE"]) for node in list(self.cluster.nodes.values())] # The first node sends NEW_NODE for the other 2 nodes during startup, in case they are # late due to network delays let's block a bit longer logger.debug("Waiting for unwanted notifications....") waiters[0].wait_for_notifications(timeout=30, num_notifications=2) waiters[0].clear_notifications() logger.debug("Issuing move command....") node1 = list(self.cluster.nodes.values())[0] node1.move("123") for waiter in waiters: logger.debug("Waiting for notification from {}".format(waiter.address,)) notifications = waiter.wait_for_notifications(60.0) assert 1 == len(notifications), notifications notification = notifications[0] change_type = notification["change_type"] address, port = notification["address"] > assert "MOVED_NODE" == change_type E AssertionError: assert 'MOVED_NODE' == 'NEW_NODE' E - NEW_NODE E + MOVED_NODE pushed_notifications_test.py:118: AssertionError