You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by "Caleb Rackliffe (Jira)" <ji...@apache.org> on 2025/02/04 00:56:00 UTC
[jira] [Assigned] (CASSANDRA-20243) ALLOW FILTERING returned data that doesn't match the single column condition.
[ https://issues.apache.org/jira/browse/CASSANDRA-20243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Caleb Rackliffe reassigned CASSANDRA-20243:
-------------------------------------------
Assignee: Caleb Rackliffe
> ALLOW FILTERING returned data that doesn't match the single column condition.
> -----------------------------------------------------------------------------
>
> Key: CASSANDRA-20243
> URL: https://issues.apache.org/jira/browse/CASSANDRA-20243
> Project: Apache Cassandra
> Issue Type: Bug
> Components: Consistency/Coordination
> Reporter: David Capwell
> Assignee: Caleb Rackliffe
> Priority: Normal
> Fix For: 5.x
>
>
> This was found by CASSANDRA-20156
> The following history returns extra data that doesn’t match the condition
> {code}
> History:
> 19: INSERT INTO ks1.tbl (pk0, ck0, ck1, v0, v2) VALUES ('滲魶潁ꧏ', '㳩륓彫澳炬ᔕ?', 0x00000000000014008f00000000000000, 'a559:fe1:d87b:25:c95e:9029:44e5:6ad2', 1.85573747E16 + 1.3498884E31) -- on node2
> 21: INSERT INTO ks1.tbl (pk0, ck0, ck1, s0, s1, v0, v1, v2) VALUES ('滲魶潁ꧏ', '᱓흩窡' + '㯪?竲翐尞绸봧헑ꑖ', 0x0000000000004800a900000000000000, 00000000-0000-4900-b600-000000000000, 00000000-0000-1900-ac00-000000000000, '170.247.202.199', 7538904746043055610 + 7400846939126123242, -5.0338443E-27) -- on node3
> 22: SELECT * FROM ks1.tbl WHERE ck1 = 0x0000000000004800a900000000000000 ALLOW FILTERING -- ck1 'org.apache.cassandra.db.marshal.LexicalUUIDType' (reversed), on node1, fetch size 100
> {code}
> This fails with
> {code}
> Caused by: java.lang.AssertionError: Unexpected rows found:
> pk0 | ck0 | ck1 | s0 | s1 | v0 | v1 | v2
> '滲魶潁ꧏ' | '㳩륓彫澳炬ᔕ?' | 0x00000000000014008f00000000000000 | 00000000-0000-4900-b600-000000000000 | 00000000-0000-1900-ac00-000000000000 | 'a559:fe1:d87b:25:c95e:9029:44e5:6ad2' | null | 1.3498884E31
> Expected:
> pk0 | ck0 | ck1 | s0 | s1 | v0 | v1 | v2
> '滲魶潁ꧏ' | '᱓흩窡㯪?竲翐尞绸봧헑ꑖ' | 0x0000000000004800a900000000000000 | 00000000-0000-4900-b600-000000000000 | 00000000-0000-1900-ac00-000000000000 | '170.247.202.199' | -3506992388540372764 | -5.0338443E-27
> {code}
> Took this and created a non-fuzz test to repo
> {code}
> public class RepoTest extends TestBaseImpl
> {
> private static final Logger logger = LoggerFactory.getLogger(RepoTest.class);
> @Test
> public void test() throws IOException
> {
> boolean singleNode = false;
> try (Cluster cluster = Cluster.build(singleNode ? 1 : 3).start())
> {
> schemaChanges(cluster, "\t\tCREATE KEYSPACE IF NOT EXISTS ks1 WITH replication = {'class': 'SimpleStrategy', 'replication_factor': "+(singleNode ? 1 : 3)+"};\n" +
> "\t\tCREATE TABLE ks1.tbl (\n" +
> "\t\t pk0 text,\n" +
> "\t\t ck0 text,\n" +
> "\t\t ck1 'org.apache.cassandra.db.marshal.LexicalUUIDType',\n" +
> "\t\t s0 uuid static,\n" +
> "\t\t s1 timeuuid static,\n" +
> "\t\t v0 inet,\n" +
> "\t\t v1 bigint,\n" +
> "\t\t v2 float,\n" +
> "\t\t PRIMARY KEY (pk0, ck0, ck1)\n" +
> "\t\t) WITH CLUSTERING ORDER BY (ck0 DESC, ck1 DESC)\n" +
> "\t\t AND additional_write_policy = '99p'\n" +
> "\t\t AND allow_auto_snapshot = true\n" +
> "\t\t AND bloom_filter_fp_chance = 0.01\n" +
> "\t\t AND caching = {'keys': 'ALL', 'rows_per_partition': 'NONE'}\n" +
> "\t\t AND cdc = false\n" +
> "\t\t AND comment = ''\n" +
> "\t\t AND compaction = {'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32', 'min_threshold': '4'}\n" +
> "\t\t AND compression = {'chunk_length_in_kb': '16', 'class': 'org.apache.cassandra.io.compress.LZ4Compressor'}\n" +
> "\t\t AND memtable = 'default'\n" +
> "\t\t AND crc_check_chance = 1.0\n" +
> "\t\t AND fast_path = 'keyspace'\n" +
> "\t\t AND default_time_to_live = 0\n" +
> "\t\t AND extensions = {}\n" +
> "\t\t AND gc_grace_seconds = 864000\n" +
> "\t\t AND incremental_backups = true\n" +
> "\t\t AND max_index_interval = 2048\n" +
> "\t\t AND memtable_flush_period_in_ms = 0\n" +
> "\t\t AND min_index_interval = 128\n" +
> "\t\t AND read_repair = 'BLOCKING'\n" +
> "\t\t AND transactional_mode = 'off'\n" +
> "\t\t AND transactional_migration_from = 'none'\n" +
> "\t\t AND speculative_retry = '99p';\n"
> );
> cluster.get(singleNode ? 1 : 2).executeInternal("INSERT INTO ks1.tbl (pk0, ck0, ck1, v0, v2) VALUES ('滲魶\uE2F7潁ꧏ', '㳩륓\uE799彫澳\uF38E炬\uEC9Dᔕ?', 0x00000000000014008f00000000000000, 'a559:fe1:d87b:25:c95e:9029:44e5:6ad2', 1.85573747E16 + 1.3498884E31)");
> cluster.get(singleNode ? 1 : 3).executeInternal("INSERT INTO ks1.tbl (pk0, ck0, ck1, s0, s1, v0, v1, v2) VALUES ('滲魶\uE2F7潁ꧏ', '᱓흩窡' + '㯪?竲\uEE38翐尞绸봧헑ꑖ', 0x0000000000004800a900000000000000, 00000000-0000-4900-b600-000000000000, 00000000-0000-1900-ac00-000000000000, '170.247.202.199', 7538904746043055610 + 7400846939126123242, -5.0338443E-27)");
> var qr = cluster.get(1).coordinator().executeWithResult("SELECT * FROM ks1.tbl WHERE ck1 = 0x0000000000004800a900000000000000 ALLOW FILTERING", ConsistencyLevel.ALL);
> AssertUtils.assertRows(qr, QueryResults.builder()
> .row("滲魶\uE2F7潁ꧏ", // pk0
> "᱓흩窡㯪?竲\uEE38翐尞绸봧헑ꑖ", // ck0
> UUID.fromString("00000000-0000-4800-a900-000000000000"), // ck1. The CQL literal is "0x0000000000004800a900000000000000" as this is a LexicalUUIDType, but jvm-dtest converts this to a UUID in the resultset
> UUID.fromString("00000000-0000-4900-b600-000000000000"), // s0
> UUID.fromString("00000000-0000-1900-ac00-000000000000"), // s1
> InetAddress.getByName("170.247.202.199"), // v0
> -3506992388540372764L, // v1
> -5.0338443E-27F // v2
> )
> .build());
> }
> }
> private static void schemaChanges(Cluster cluster, String cql)
> {
> for (String change : Splitter.on(';').omitEmptyStrings().trimResults().splitToList(cql))
> {
> logger.warn("Schema change: {}", change);
> cluster.schemaChange(change);
> }
> }
> }
> {code}
> This fails because the first write (which doesn’t match the condition) got returned… only the second write is expected.
> I ran the test with single node and multi node, and this looks to only fail when on multi node
--
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