This is an automated email from the ASF dual-hosted git repository.
mck pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-dtest.git
The following commit(s) were added to refs/heads/trunk by this push:
new 4b7b860e Add @pytest.mark.no_vnodes to upgrade_tests/cql_tests that
are using an ordered partitioner
4b7b860e is described below
commit 4b7b860e7b4351cb72ae7f28908aebce644a89cd
Author: Mick Semb Wever <[email protected]>
AuthorDate: Wed Sep 13 09:43:46 2023 +0200
Add @pytest.mark.no_vnodes to upgrade_tests/cql_tests that are using an
ordered partitioner
And fix storage_engine_upgrade_test.py and upgrade_through_versions_test.py
so node2 has same dc as node1
patch by Mick Semb Wever; reviewed by Brandon Williams, Ekaterina
Dimitrova, Josh McKenzie, Maxim Muzafarov for CASSANDRA-18832
---
upgrade_tests/cql_tests.py | 10 ++++++++++
upgrade_tests/storage_engine_upgrade_test.py | 2 +-
upgrade_tests/upgrade_through_versions_test.py | 2 +-
3 files changed, 12 insertions(+), 2 deletions(-)
diff --git a/upgrade_tests/cql_tests.py b/upgrade_tests/cql_tests.py
index 0b5f71cb..3e791a32 100644
--- a/upgrade_tests/cql_tests.py
+++ b/upgrade_tests/cql_tests.py
@@ -303,6 +303,7 @@ class TestCQL(UpgradeTester):
[24, 'Something something', 'Frodo Baggins'],
[30, 'Yet one more message', None]])
+ @pytest.mark.no_vnodes
def test_limit_ranges(self):
""" Validate LIMIT option for 'range queries' in SELECT statements """
cursor = self.prepare(ordered=True)
@@ -1137,6 +1138,7 @@ class TestCQL(UpgradeTester):
assert_all(cursor, "SELECT * FROM users WHERE KEY='user1'", [])
+ @pytest.mark.no_vnodes
def test_undefined_column_handling(self):
cursor = self.prepare(ordered=True)
@@ -1663,6 +1665,7 @@ class TestCQL(UpgradeTester):
cursor.execute("INSERT INTO test (k, c) VALUES (2, 2)")
assert_one(cursor, "SELECT * FROM test", [2, 2, None, None])
+ @pytest.mark.no_vnodes
def test_only_pk(self):
"""
Check table with only a PK (part of #4361)
@@ -1763,6 +1766,7 @@ class TestCQL(UpgradeTester):
assert_row_count(cursor, 'test', 2)
+ @pytest.mark.no_vnodes
def test_composite_index_with_pk(self):
cursor = self.prepare(ordered=True)
@@ -1826,6 +1830,7 @@ class TestCQL(UpgradeTester):
assert_invalid(cursor, "SELECT content FROM blogs WHERE time1
= 1 AND time2 = 1 AND author='foo'")
assert_invalid(cursor, "SELECT content FROM blogs WHERE time1
= 1 AND time2 > 0 AND author='foo'")
+ @pytest.mark.no_vnodes
def test_limit_bugs(self):
"""
Test for LIMIT bugs from #4579
@@ -1914,6 +1919,7 @@ class TestCQL(UpgradeTester):
assert_invalid(cursor, "SELECT * FROM compositetest WHERE
ctime>=12345679 AND key='key3' AND ctime<=12345680 LIMIT 3;")
assert_invalid(cursor, "SELECT * FROM compositetest WHERE
ctime=12345679 AND key='key3' AND ctime<=12345680 LIMIT 3;")
+ @pytest.mark.no_vnodes
def test_order_by_multikey(self):
"""
Test for #4612 bug and more generally order by when multiple C* rows
are queried
@@ -2341,6 +2347,7 @@ class TestCQL(UpgradeTester):
assert_one(cursor, "SELECT l1, l2 FROM test WHERE k = 0", [[1, 24,
3], [4, 42, 6]])
+ @pytest.mark.no_vnodes
def test_composite_index_collections(self):
cursor = self.prepare(ordered=True)
cursor.execute("""
@@ -2370,6 +2377,7 @@ class TestCQL(UpgradeTester):
assert_all(cursor, query, [[1, set(['bar1', 'bar2'])], [1,
set(['bar2', 'bar3'])], [2, set(['baz'])]])
@pytest.mark.skip("https://issues.apache.org/jira/browse/CASSANDRA-14961";)
+ @pytest.mark.no_vnodes
def test_truncate_clean_cache(self):
cursor = self.prepare(ordered=True, use_cache=True)
@@ -3212,6 +3220,7 @@ class TestCQL(UpgradeTester):
assert_invalid(cursor, "DELETE FROM test2 WHERE k = 0 AND i >
0 IF EXISTS")
assert_invalid(cursor, "DELETE FROM test2 WHERE k = 0 AND i >
0 IF v = 'foo'")
+ @pytest.mark.no_vnodes
def test_range_key_ordered(self):
cursor = self.prepare(ordered=True)
@@ -3358,6 +3367,7 @@ class TestCQL(UpgradeTester):
assert_one(cursor, "SELECT * FROM test", [1, set([2])])
+ @pytest.mark.no_vnodes
def test_select_distinct(self):
cursor = self.prepare(ordered=True)
diff --git a/upgrade_tests/storage_engine_upgrade_test.py
b/upgrade_tests/storage_engine_upgrade_test.py
index cb0880f6..37ac9e9b 100644
--- a/upgrade_tests/storage_engine_upgrade_test.py
+++ b/upgrade_tests/storage_engine_upgrade_test.py
@@ -74,7 +74,7 @@ class TestStorageEngineUpgrade(Tester):
cluster.set_install_dir(install_dir=self.fixture_dtest_setup.default_install_dir)
self.install_nodetool_legacy_parsing()
# Add a new node, bootstrap=True ensures that it is not a seed
- node2 = new_node(cluster, bootstrap=True)
+ node2 = new_node(cluster, bootstrap=True,
data_center=node1.data_center)
node2.start(wait_for_binary_proto=True,
jvm_args=self.fixture_dtest_setup.jvm_args)
temp_files = self.glob_data_dirs(os.path.join('*', "tmp", "*.dat"))
diff --git a/upgrade_tests/upgrade_through_versions_test.py
b/upgrade_tests/upgrade_through_versions_test.py
index d88249f9..939dd1a5 100644
--- a/upgrade_tests/upgrade_through_versions_test.py
+++ b/upgrade_tests/upgrade_through_versions_test.py
@@ -811,7 +811,7 @@ class BootstrapMixin(object):
def _bootstrap_new_node(self):
# Check we can bootstrap a new node on the upgraded cluster:
logger.debug("Adding a node to the cluster")
- nnode = new_node(self.cluster, remote_debug_port=str(2000 +
len(self.cluster.nodes)))
+ nnode = new_node(self.cluster, remote_debug_port=str(2000 +
len(self.cluster.nodes)), data_center=self.cluster.nodelist()[0].data_center)
if nnode.get_cassandra_version() >= '4.2':
nnode.set_configuration_options({'enable_scripted_user_defined_functions':
'false'})
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
