[ 
https://issues.apache.org/jira/browse/CASSANDRA-20196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912618#comment-17912618
 ] 

David Capwell commented on CASSANDRA-20196:
-------------------------------------------

going to send a note to the ML about this and that will end the work for this 
ticket.  CASSANDRA-20108 fixes the issue so this ticket just needs to bring 
awareness to that

> 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: David Capwell
>            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:java}
> 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:java}
>               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:java}
> /*
>  * 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 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 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);
>             SimpleQueryResult actual = builder.build();
>             
> Assertions.assertThat(actual.toObjectArrays().length).isEqualTo(expected.toObjectArrays().length);
>             AssertUtils.assertRows(actual, expected);
>         }
>     }
> } {code}
> This fails with
> {code:java}
> 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: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org

Reply via email to