[ 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