[
https://issues.apache.org/jira/browse/CASSANDRA-20196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Capwell updated CASSANDRA-20196:
--------------------------------------
Bug Category: Parent values: Correctness(12982)Level 1 values: Transient
Incorrect Response(12987)
Complexity: Normal
Discovered By: Fuzz Test
Fix Version/s: 5.x
Severity: Critical
Status: Open (was: Triage Needed)
> ALLOW FILTERING with Paging can miss results
> --------------------------------------------
>
> Key: CASSANDRA-20196
> URL: https://issues.apache.org/jira/browse/CASSANDRA-20196
> Project: Apache Cassandra
> Issue Type: Bug
> Components: Accord
> Reporter: David Capwell
> Assignee: Ariel Weisberg
> Priority: Normal
> Fix For: 5.x
>
>
> This was found by CASSANDRA-20156.
> The following select works just fine when paging is not requested, but once
> paging is requested it misses results.
> {code}
> SELECT * FROM ks7.tbl WHERE s0 <= '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda'
> ALLOW FILTERING
> {code}
> The error reported from CASSANDRA-20156 is
> {code}
> 142: SELECT * FROM ks1.tbl WHERE s0 <=
> '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda' ALLOW FILTERING; -- s0 inet, on
> node1, fetch size 1
> at accord.utils.Property$StatefulBuilder.check(Property.java:504)
> at
> org.apache.cassandra.distributed.test.cql3.SingleNodeTableWalkTest.test(SingleNodeTableWalkTest.java:281)
> Caused by: java.lang.AssertionError: Missing rows:
> pk0 | ck0
> | ck1 | s0
> | v0
> 'f825:7493:4d15:2938:4b7c:7ce7:775e:601f' |
> '3013:225a:ec45:b743:9fc5:4d4b:f487:2e4' |
> 'e852:5351:1cb:b86:6d19:bc5f:cfb9:2411' |
> '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda' |
> '3cea:18ad:7d39:783:4f2d:c984:86d0:618e'
> 'f825:7493:4d15:2938:4b7c:7ce7:775e:601f' |
> '9058:ea8e:5bb7:17e2:e876:9e6b:f24f:3bba' |
> 'b27e:feee:d5c6:250f:3352:d9d1:c910:7975' |
> '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda' |
> 'b673:7639:5208:650b:ed64:e982:11f2:187f'
> 'f825:7493:4d15:2938:4b7c:7ce7:775e:601f' |
> 'c202:4901:ffce:9b2f:420d:f00f:741f:3f' |
> 'b8b6:7f37:7e9d:c368:23c5:ba5a:95e8:873e' |
> '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda' |
> 'd8a:e824:c54:aa53:c0fd:bdac:d1b0:912d'
> 'f825:7493:4d15:2938:4b7c:7ce7:775e:601f' |
> '98b9:b33a:cc72:d569:e333:8e3b:2810:faa3' |
> '41ea:5e86:2608:5057:6fd2:a5d2:9631:f033' |
> '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda' |
> '110a:d2cf:1212:6411:3d91:6af5:6bc1:ce81'
> Expected:
> pk0 | ck0
> | ck1 | s0
> | v0
> '8646:35a3:7833:6ea7:132f:fa4e:2cef:39f0' |
> '5dd0:de6a:d3a0:8e3c:c5a2:c03:9a59:1a1' |
> '36ef:dc79:31d0:7f7e:236a:7013:3354:bbc8' |
> '56ee:b553:647b:1a3d:cccc:718:25fd:f094' |
> 'e6bf:b16a:ca05:768b:477d:3e08:b6c2:e82'
> 'f825:7493:4d15:2938:4b7c:7ce7:775e:601f' |
> '3013:225a:ec45:b743:9fc5:4d4b:f487:2e4' |
> 'e852:5351:1cb:b86:6d19:bc5f:cfb9:2411' |
> '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda' |
> '3cea:18ad:7d39:783:4f2d:c984:86d0:618e'
> '8646:35a3:7833:6ea7:132f:fa4e:2cef:39f0' |
> '176c:731f:44d:4798:a840:ee6c:7957:2153' |
> '7072:ae6:95c5:5c39:979d:f2df:b3c0:11e9' |
> '56ee:b553:647b:1a3d:cccc:718:25fd:f094' |
> '7c19:3e31:bb44:f078:bd7d:9acb:9d51:9a78'
> '8646:35a3:7833:6ea7:132f:fa4e:2cef:39f0' |
> '331d:d901:5bee:bab8:24e3:ac02:a4a3:c6b9' |
> '52d:797:bbf1:2502:9cc8:8639:84ff:3e26' |
> '56ee:b553:647b:1a3d:cccc:718:25fd:f094' |
> '79d5:51d4:b887:fe9d:9137:5f84:4e4c:1451'
> 'f825:7493:4d15:2938:4b7c:7ce7:775e:601f' |
> '9058:ea8e:5bb7:17e2:e876:9e6b:f24f:3bba' |
> 'b27e:feee:d5c6:250f:3352:d9d1:c910:7975' |
> '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda' |
> 'b673:7639:5208:650b:ed64:e982:11f2:187f'
> 'f825:7493:4d15:2938:4b7c:7ce7:775e:601f' |
> 'c202:4901:ffce:9b2f:420d:f00f:741f:3f' |
> 'b8b6:7f37:7e9d:c368:23c5:ba5a:95e8:873e' |
> '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda' |
> 'd8a:e824:c54:aa53:c0fd:bdac:d1b0:912d'
> 'f825:7493:4d15:2938:4b7c:7ce7:775e:601f' |
> '98b9:b33a:cc72:d569:e333:8e3b:2810:faa3' |
> '41ea:5e86:2608:5057:6fd2:a5d2:9631:f033' |
> '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda' |
> '110a:d2cf:1212:6411:3d91:6af5:6bc1:ce81'
> at
> org.apache.cassandra.harry.model.ASTSingleTableModel.validateAnyOrder(ASTSingleTableModel.java:457)
> at
> org.apache.cassandra.harry.model.ASTSingleTableModel.validate(ASTSingleTableModel.java:426)
> at
> org.apache.cassandra.harry.model.ASTSingleTableModel.validate(ASTSingleTableModel.java:420)
> at
> org.apache.cassandra.harry.model.ASTSingleTableModel.validate(ASTSingleTableModel.java:414)
> {code}
> I was able to reproduce outside of the model by using the non-paging result
> as the expected case; the test is below. One issue I found was that I wasn’t
> able to shrink the test, when I limited to the partitions expected in the
> results the test passes, so partitions must be present that are not in the
> result to trigger this issue
> {code}
> /*
> * Licensed to the Apache Software Foundation (ASF) under one
> * or more contributor license agreements. See the NOTICE file
> * distributed with this work for additional information
> * regarding copyright ownership. The ASF licenses this file
> * to you under the Apache License, Version 2.0 (the
> * "License"); you may not use this file except in compliance
> * with the License. You may obtain a copy of the License at
> *
> * http://www.apache.org/licenses/LICENSE-2.0
> *
> * Unless required by applicable law or agreed to in writing, software
> * distributed under the License is distributed on an "AS IS" BASIS,
> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
> * See the License for the specific language governing permissions and
> * limitations under the License.
> */
> package org.apache.cassandra.distributed.test.cql3;
> import java.io.IOException;
> import java.util.function.Consumer;
> import org.junit.Test;
> import org.apache.cassandra.distributed.Cluster;
> import org.apache.cassandra.distributed.api.ConsistencyLevel;
> import org.apache.cassandra.distributed.api.QueryResult;
> import org.apache.cassandra.distributed.api.QueryResults;
> import org.apache.cassandra.distributed.api.SimpleQueryResult;
> import org.apache.cassandra.distributed.test.TestBaseImpl;
> import org.apache.cassandra.distributed.util.QueryResultUtil;
> public class RepoTest extends TestBaseImpl
> {
> @Test
> public void test() throws IOException
> {
> try (Cluster cluster = Cluster.build(1).start())
> {
> cluster.schemaChange("CREATE KEYSPACE IF NOT EXISTS ks7 WITH
> replication = {'class': 'SimpleStrategy', 'replication_factor': 1};");
> String createTableCQL = "CREATE TABLE ks7.tbl (\n" +
> "\t\t pk0 inet,\n" +
> "\t\t ck0 inet,\n" +
> "\t\t ck1 inet,\n" +
> "\t\t s0 inet static,\n" +
> "\t\t v0 inet,\n" +
> "\t\t PRIMARY KEY (pk0, ck0, ck1)\n" +
> "\t\t) WITH CLUSTERING ORDER BY (ck0 ASC, ck1
> ASC)\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'";
> cluster.schemaChange(createTableCQL);
>
> Consumer<String> write = cql ->
> cluster.coordinator(1).execute(cql, ConsistencyLevel.ALL);
> write.accept("DELETE FROM ks7.tbl WHERE pk0 =
> '9018:341b:ddc1:480d:32dd:a593:2144:5885'");
> write.accept("INSERT INTO ks7.tbl (pk0, ck0, ck1, s0, v0) VALUES
> ('9018:341b:ddc1:480d:32dd:a593:2144:5885',
> '31b9:7c6:c0e6:7e31:ce41:b8bc:62aa:5787',
> '7292:c2ae:97d6:c48c:bd17:6809:67cf:3ab2',
> 'c21c:836e:f21e:1418:b20c:972e:d8ca:b99b',
> '3c9f:fdc4:c612:66ca:2fd1:2d93:485f:758')");
> write.accept("UPDATE ks7.tbl SET
> v0='d732:ef19:b324:8a42:11ed:57c4:af60:2b2e' WHERE pk0 =
> '74be:a59f:2fad:a07f:421:2c42:2f6b:7b44' AND ck0 =
> '4388:84f1:c8db:b5e1:b983:6a39:e790:2365' AND ck1 =
> '6be7:2252:88cc:5983:c4c5:4b1d:b4c7:6409'");
> write.accept("UPDATE ks7.tbl SET
> v0='f16f:aa12:16bf:4ab7:71cf:8ad0:a055:3921' WHERE pk0 =
> '69a4:7900:ba79:d40:b371:73b2:ca47:c799' AND ck0 =
> 'fcef:27f8:9902:47e3:12e9:c601:5630:f4b7' AND ck1 =
> '1573:f440:852f:4809:22e7:296c:60db:ad4b'");
> write.accept("DELETE FROM ks7.tbl WHERE pk0 =
> '74be:a59f:2fad:a07f:421:2c42:2f6b:7b44' AND ck0 =
> '84c0:babe:551c:67e1:bacc:5989:4183:4cb1' AND ck1 =
> 'e9ff:9b5e:c33d:fbb1:6b07:e39a:167e:ba3c'");
> write.accept("INSERT INTO ks7.tbl (pk0, ck0, ck1, s0, v0) VALUES
> ('bb20:2eed:15e9:aa5e:dc7e:5bb8:2d19:876c',
> 'd625:424a:b02d:8fee:2513:75bf:f560:7328',
> 'a8ef:89f0:15fa:1921:925f:5d0e:d10f:922f',
> '7dcb:8852:8c1b:6235:3bc2:3f0f:81f4:11c2',
> 'c139:f2e6:2e9b:3956:acfd:be99:2d12:dc43')");
> write.accept("DELETE FROM ks7.tbl WHERE pk0 =
> 'bb20:2eed:15e9:aa5e:dc7e:5bb8:2d19:876c' AND ck0 =
> '9874:7f9b:eba:fc23:2e2a:ed20:1240:97b8' AND ck1 =
> '6bf:43b:6870:52f:b49c:5370:1031:3aaf'");
> write.accept("UPDATE ks7.tbl SET
> s0='60b4:4cd7:ac63:4e91:4ac7:c8ce:2904:3956',
> v0='82ba:37bb:8ee1:d5fd:77ed:3807:2304:2d1b' WHERE pk0 =
> 'bb20:2eed:15e9:aa5e:dc7e:5bb8:2d19:876c' AND ck0 =
> '96d5:a967:a4bb:2a23:ede2:4bb4:e869:97a1' AND ck1 =
> 'b1b7:7c3c:811d:3bf7:7558:20:5a86:8fd4'");
> write.accept("UPDATE ks7.tbl SET
> v0='3908:f104:ca55:63b9:885:ca2d:c7c4:76f9',
> s0='58c:8afb:edf1:9c45:9e32:86f7:e47c:7a45' WHERE pk0 =
> '9018:341b:ddc1:480d:32dd:a593:2144:5885' AND ck0 =
> '57:c2c:5e63:ca49:3ffd:41f4:2a86:2629' AND ck1 =
> 'ddc7:3ee8:d325:b1fb:7846:122e:951a:7106'");
> write.accept("DELETE FROM ks7.tbl WHERE pk0 =
> '68af:5ada:33b8:cf55:955e:8ce3:cc8a:7e7b'");
> write.accept("INSERT INTO ks7.tbl (pk0, ck0, ck1, s0, v0) VALUES
> ('69a4:7900:ba79:d40:b371:73b2:ca47:c799',
> '22c9:ad76:7e50:9d06:d3d4:3d56:39cb:367b',
> 'dbc2:b754:c2c8:61ea:3919:d52:e035:2cbf',
> 'd57f:d835:c552:4122:c771:4eaa:e452:d26f',
> '319e:fdba:2b8c:2333:307:a3fb:b2e8:ef52')");
> write.accept("UPDATE ks7.tbl SET
> v0='7580:3421:e9bc:9dfe:e8b0:c39e:6667:66e7' WHERE pk0 =
> '69a4:7900:ba79:d40:b371:73b2:ca47:c799' AND ck0 =
> '8423:7b80:cabb:2803:b7cf:22f3:8893:f3d5' AND ck1 =
> 'b706:be8:63a7:1e69:e65a:d9c9:f177:8dc1'");
> write.accept("INSERT INTO ks7.tbl (pk0, ck0, ck1, s0) VALUES
> ('68af:5ada:33b8:cf55:955e:8ce3:cc8a:7e7b',
> 'ce50:920f:fc5f:12f7:20b3:2eea:995:99ba',
> 'e3a5:d792:467e:4b37:d967:656c:5a9a:c791',
> 'a253:cb99:808f:f444:a26:44ef:4e02:e663')");
> write.accept("UPDATE ks7.tbl SET
> v0='79d5:51d4:b887:fe9d:9137:5f84:4e4c:1451',
> s0='d62:c531:c559:6e8b:416f:36ee:c295:1f0d' WHERE pk0 =
> '8646:35a3:7833:6ea7:132f:fa4e:2cef:39f0' AND ck0 =
> '331d:d901:5bee:bab8:24e3:ac02:a4a3:c6b9' AND ck1 =
> '52d:797:bbf1:2502:9cc8:8639:84ff:3e26'");
> write.accept("UPDATE ks7.tbl SET
> v0='e6bf:b16a:ca05:768b:477d:3e08:b6c2:e82',
> s0='bfb9:bd7a:e346:1366:a55:41f6:b0e2:ab5f' WHERE pk0 =
> '8646:35a3:7833:6ea7:132f:fa4e:2cef:39f0' AND ck0 =
> '5dd0:de6a:d3a0:8e3c:c5a2:c03:9a59:1a1' AND ck1 =
> '36ef:dc79:31d0:7f7e:236a:7013:3354:bbc8'");
> write.accept("INSERT INTO ks7.tbl (pk0, ck0, ck1, s0, v0) VALUES
> ('f825:7493:4d15:2938:4b7c:7ce7:775e:601f',
> 'c202:4901:ffce:9b2f:420d:f00f:741f:3f',
> 'b8b6:7f37:7e9d:c368:23c5:ba5a:95e8:873e',
> '633a:c501:3e58:348b:ddf7:1b31:93a3:cd5',
> 'd8a:e824:c54:aa53:c0fd:bdac:d1b0:912d')");
> write.accept("INSERT INTO ks7.tbl (pk0, ck0, ck1, s0, v0) VALUES
> ('74be:a59f:2fad:a07f:421:2c42:2f6b:7b44',
> '6a:a596:72f1:ee91:82e4:1d2f:9739:171b',
> '5a27:2478:fe2:7935:17fa:3689:7084:8bd0',
> '7982:338c:b609:256a:2886:1609:3ad3:2b37',
> '5da9:60cc:3b3:b7c8:51e6:838a:eab2:35b9')");
> write.accept("INSERT INTO ks7.tbl (pk0, ck0, ck1, s0, v0) VALUES
> ('69a4:7900:ba79:d40:b371:73b2:ca47:c799',
> '5b0f:3f99:89e:7b8d:70a7:c1df:44ef:d68',
> '681e:f718:7b78:c63e:6a31:720d:414e:728d',
> 'fc11:1d3f:fa96:88c0:3874:1a49:922f:fc3d',
> '196b:612e:3522:1172:ca00:4aef:97bb:bbdf')");
> write.accept("DELETE FROM ks7.tbl WHERE pk0 =
> '9018:341b:ddc1:480d:32dd:a593:2144:5885' AND ck0 =
> 'ce5f:9b40:3291:1942:b54a:157b:2824:32be' AND ck1 =
> '7533:6d8d:e460:f40f:a98a:2958:6c4a:d004'");
> write.accept("UPDATE ks7.tbl SET
> s0='12f0:8b3c:9efd:b56b:db7e:deec:3003:f1a5',
> v0='acfb:6840:daf:35a9:511c:6ab5:ea53:e8f4' WHERE pk0 =
> '68af:5ada:33b8:cf55:955e:8ce3:cc8a:7e7b' AND ck0 =
> '596a:9b18:b3fe:123b:340f:f003:6f4a:2c0d' AND ck1 =
> 'd875:4f38:353c:3863:62b2:46bd:10ab:4049'");
> write.accept("UPDATE ks7.tbl SET
> v0='dada:ddc2:8578:204a:8028:ca09:4cac:b122' WHERE pk0 =
> '69a4:7900:ba79:d40:b371:73b2:ca47:c799' AND ck0 =
> 'a42a:9bea:2174:a5:ac0:9a0b:272b:c312' AND ck1 =
> 'db9c:2885:2e2a:9f67:af8a:3e3d:aff7:d5ac'");
> write.accept("UPDATE ks7.tbl SET
> s0='90e2:ecfb:21cd:8146:aa7d:9eeb:6a4d:b4b6',
> v0='c95:bb7a:3e10:a13d:90bb:2704:7485:dd4f' WHERE pk0 =
> 'bb20:2eed:15e9:aa5e:dc7e:5bb8:2d19:876c' AND ck0 =
> 'd84b:dc78:bb0:95:cbaa:e507:d1e9:4769' AND ck1 =
> '579e:3a43:de1b:580d:fed7:e799:1a17:72a'");
> write.accept("DELETE FROM ks7.tbl WHERE pk0 =
> '9018:341b:ddc1:480d:32dd:a593:2144:5885' AND ck0 =
> 'c3b5:5a23:e085:9e53:4049:e9f6:5a48:9a36' AND ck1 =
> '1de3:d9b4:3e2d:14b5:cf9d:92b0:2537:7fa1'");
> write.accept("INSERT INTO ks7.tbl (pk0, ck0, ck1, s0, v0) VALUES
> ('bb20:2eed:15e9:aa5e:dc7e:5bb8:2d19:876c',
> '9eb9:5bda:2dd4:ffb0:1ace:5a7e:2962:aae8',
> '43a3:f4da:51eb:7fb2:97f6:a8ed:aa11:def4',
> 'dd00:3f47:eb26:bf79:c3bf:5d09:5f1d:10b5',
> 'e4d6:967e:5a54:4f65:b7d5:866a:e79b:d999')");
> write.accept("DELETE v0, s0 FROM ks7.tbl WHERE pk0 =
> '68af:5ada:33b8:cf55:955e:8ce3:cc8a:7e7b' AND ck0 =
> '8aa6:7d92:316e:1dfe:bcb1:9cb:47c6:35cc' AND ck1 =
> '6b4:741c:88c4:3e2e:2712:ed77:3ba5:552b'");
> write.accept("UPDATE ks7.tbl SET
> s0='c57e:dd2e:895d:3463:e935:fa:6dc8:d32f',
> v0='1aa9:78af:33:f0ed:2907:34bc:8523:b677' WHERE pk0 =
> 'bb20:2eed:15e9:aa5e:dc7e:5bb8:2d19:876c' AND ck0 =
> 'ef57:ca58:bf32:5704:4b58:dadd:857c:4ebd' AND ck1 =
> '21ad:5d0b:a6e4:a35c:7090:baa0:7bb1:509f'");
> write.accept("INSERT INTO ks7.tbl (pk0, ck0, ck1, s0, v0) VALUES
> ('8646:35a3:7833:6ea7:132f:fa4e:2cef:39f0',
> '176c:731f:44d:4798:a840:ee6c:7957:2153',
> '7072:ae6:95c5:5c39:979d:f2df:b3c0:11e9',
> '56ee:b553:647b:1a3d:cccc:718:25fd:f094',
> '7c19:3e31:bb44:f078:bd7d:9acb:9d51:9a78')");
> write.accept("DELETE FROM ks7.tbl WHERE pk0 =
> 'bb20:2eed:15e9:aa5e:dc7e:5bb8:2d19:876c'");
> write.accept("DELETE FROM ks7.tbl WHERE pk0 =
> '8646:35a3:7833:6ea7:132f:fa4e:2cef:39f0' AND ck0 =
> '982b:d0c7:ecdf:b418:29d5:fd34:4e5:e8fa' AND ck1 =
> '5266:bdb8:b2a4:a809:fa7e:3af5:2ec5:7c99'");
> write.accept("UPDATE ks7.tbl SET
> s0='9bfd:e546:bf26:ab70:6cbb:27bf:721f:845c',
> v0='1e8b:fd1:341e:6085:9f5a:278c:cccf:d58e' WHERE pk0 =
> '9018:341b:ddc1:480d:32dd:a593:2144:5885' AND ck0 =
> 'cb1f:e454:3bd9:a108:20dd:3338:74e2:d19f' AND ck1 =
> 'b4:1fe5:8934:951:4dbb:38a6:898f:d082'");
> write.accept("DELETE v0, s0, s0 FROM ks7.tbl WHERE pk0 =
> '68af:5ada:33b8:cf55:955e:8ce3:cc8a:7e7b' AND ck0 =
> '4573:1472:f24b:660d:5152:4d17:1fc0:ffc4' AND ck1 =
> 'd031:bfba:3e93:74ef:55ee:c8cf:33be:aa6d'");
> write.accept("DELETE s0, s0 FROM ks7.tbl WHERE pk0 =
> '74be:a59f:2fad:a07f:421:2c42:2f6b:7b44'");
> write.accept("DELETE FROM ks7.tbl WHERE pk0 =
> '69a4:7900:ba79:d40:b371:73b2:ca47:c799' AND ck0 =
> '4249:85ce:a036:272c:be40:a4f:8a98:c3d9' AND ck1 =
> 'a1c3:11b6:e284:c4fc:360:b604:7392:aa61'");
> write.accept("DELETE s0 FROM ks7.tbl WHERE pk0 =
> 'f825:7493:4d15:2938:4b7c:7ce7:775e:601f'");
> write.accept("INSERT INTO ks7.tbl (pk0, ck0, ck1, s0, v0) VALUES
> ('f825:7493:4d15:2938:4b7c:7ce7:775e:601f',
> '3013:225a:ec45:b743:9fc5:4d4b:f487:2e4',
> 'e852:5351:1cb:b86:6d19:bc5f:cfb9:2411',
> '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda',
> '3cea:18ad:7d39:783:4f2d:c984:86d0:618e')");
> write.accept("UPDATE ks7.tbl SET
> v0='110a:d2cf:1212:6411:3d91:6af5:6bc1:ce81' WHERE pk0 =
> 'f825:7493:4d15:2938:4b7c:7ce7:775e:601f' AND ck0 =
> '98b9:b33a:cc72:d569:e333:8e3b:2810:faa3' AND ck1 =
> '41ea:5e86:2608:5057:6fd2:a5d2:9631:f033'");
> write.accept("UPDATE ks7.tbl SET
> v0='b673:7639:5208:650b:ed64:e982:11f2:187f' WHERE pk0 =
> 'f825:7493:4d15:2938:4b7c:7ce7:775e:601f' AND ck0 =
> '9058:ea8e:5bb7:17e2:e876:9e6b:f24f:3bba' AND ck1 =
> 'b27e:feee:d5c6:250f:3352:d9d1:c910:7975'");
> write.accept("DELETE FROM ks7.tbl WHERE pk0 =
> '69a4:7900:ba79:d40:b371:73b2:ca47:c799' AND ck0 =
> 'd526:e6ff:67ff:d965:f93e:f667:c37b:6734' AND ck1 =
> 'd56b:7423:61f3:9b8b:39bf:18dc:dbb6:f6d9'");
> write.accept("INSERT INTO ks7.tbl (pk0, ck0, ck1, s0, v0) VALUES
> ('69a4:7900:ba79:d40:b371:73b2:ca47:c799',
> '3b33:303c:76d8:d797:5085:81f2:956a:71ef',
> 'f991:3e13:17fb:2626:3b43:6c61:20cd:39d8',
> '8134:d23b:3682:36e8:4ef6:2345:47:64c',
> 'c490:8c9b:1724:6a3e:b97f:54f2:624f:ca64')");
>
> String select = "SELECT * FROM ks7.tbl WHERE s0 <=
> '5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda' ALLOW FILTERING";
> QueryResult qr =
> cluster.coordinator(1).executeWithPagingWithResult(select,
> ConsistencyLevel.ALL, 1);
> var builder = QueryResults.builder();
> while (qr.hasNext())
> builder.row(qr.next().toObjectArray());
> SimpleQueryResult expected =
> cluster.coordinator(1).executeWithResult(select, ConsistencyLevel.ALL);
> QueryResultUtil.assertThat(builder.build()).isEqualTo(expected);
> }
> }
> }
> {code}
> This fails with
> {code}
> java.lang.AssertionError: Expected row 3 to be
> [/f825:7493:4d15:2938:4b7c:7ce7:775e:601f,
> /3013:225a:ec45:b743:9fc5:4d4b:f487:2e4,
> /e852:5351:1cb:b86:6d19:bc5f:cfb9:2411,
> /5ccd:9adf:6c3d:658b:851c:61ca:42dd:9cda,
> /3cea:18ad:7d39:783:4f2d:c984:86d0:618e] but was missing
> at
> org.apache.cassandra.distributed.util.QueryResultUtil$SimpleQueryResultAssertHelper.isEqualTo(QueryResultUtil.java:258)
> at
> org.apache.cassandra.distributed.test.cql3.RepoTest.test(RepoTest.java:153)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
