[ https://issues.apache.org/jira/browse/CASSANDRA-19088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sam Tunnicliffe updated CASSANDRA-19088: ---------------------------------------- Bug Category: Parent values: Correctness(12982)Level 1 values: Test Failure(12990) Complexity: Normal Component/s: Test/dtest/python Discovered By: DTest Fix Version/s: 5.1-alpha1 Severity: Normal Status: Open (was: Triage Needed) > 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: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org