You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by "Michael Semb Wever (Jira)" <ji...@apache.org> on 2023/11/24 18:42:00 UTC

[jira] [Created] (CASSANDRA-19088) Test Failure: pushed_notifications_test.TestPushedNotifications.test_move_single_node

Michael Semb Wever created CASSANDRA-19088:
----------------------------------------------

             Summary: Test Failure: pushed_notifications_test.TestPushedNotifications.test_move_single_node
                 Key: CASSANDRA-19088
                 URL: https://issues.apache.org/jira/browse/CASSANDRA-19088
             Project: Cassandra
          Issue Type: Bug
            Reporter: Michael Semb Wever


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

{noformat}
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
{noformat}




--
This message was sent by Atlassian Jira
(v8.20.10#820010)

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