[
https://issues.apache.org/jira/browse/CASSANDRA-19088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Tunnicliffe updated CASSANDRA-19088:
----------------------------------------
Test and Documentation Plan: CI
Status: Patch Available (was: In Progress)
This is flaky as the nodes may start the native protocol interface before or
after learning of the new node. The linked patch makes the check independent of
the ordering. CI results to follow
[https://github.com/beobal/cassandra-dtest/commit/3500bc070e96f478ff52499d83168db6df21b379]
> 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
> Components: Test/dtest/python
> Reporter: Michael Semb Wever
> Assignee: Sam Tunnicliffe
> Priority: Normal
> Fix For: 5.1-alpha1
>
>
> 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: [email protected]
For additional commands, e-mail: [email protected]
