David Capwell created CASSANDRA-20196:
-----------------------------------------
Summary: 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
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]
