Cassandra nicht Rückkehr alle passenden Spalten mit einer „SELECT x WHERE y IN (z)“ Abfrage

Question

Ich habe folgende Spalte Familie in Cassandra:

CREATE TABLE item_index (
    foo_id text, 
    bar_id text, 
    bar_metadata text, 
    bar_url text, 
    PRIMARY KEY (foo_id, bar_id) 
) WITH 
    bloom_filter_fp_chance=0.010000 AND 
    caching='KEYS_ONLY' AND 
    comment='' AND 
    dclocal_read_repair_chance=0.000000 AND 
    gc_grace_seconds=864000 AND 
    read_repair_chance=0.100000 AND 
    replicate_on_write='true' AND 
    populate_io_cache_on_flush='false' AND 
    compaction={'class': 'SizeTieredCompactionStrategy'} AND 
    compression={'sstable_compression': 'SnappyCompressor'}; 

Ich versuche, alle Zeilen abrufen eine Liste passender 25 spezifische bar_id die diese Abfrage in cqlsh mit:

SELECT * FROM stagekeyspace.item_index WHERE foo_id IN ('1947dccc791ace5eb40dd2f00d9d876f') 
AND bar_id IN ('5f715d9f4a1a97b8fb54996bca5b0d91','64a8708d33b426315480b127a36663fd', 
'b5f788e2c5b6e0bdfa3fc76d0f3e4fac','b6da801b86fd27e7382f5b6ce6dedf4d', 
'c2e6586c0c9867157a4789a2ba3fb3c1','dc784b35764c6a3fbf083a6da59ad475', 
'09c436ce046905b018a1e3fa417ee04a','0b4b5bd9c339353f6c16fcd822f50d6b', 
'0c8e2e54c4629767b548830e122f295b','106735c6a97f8c8b006b9e0dbe18585e', 
'11135d45b78086bc386bd9e538409915','269e2fbb4ce98f74471ec2fd0fffaa7a', 
'2d2462fada062a160e60d537ab58ef81','30c617bd0dc41fde670c3796ad98ff65', 
'32b458cae9762541a64e5f60b29f064c','36884ff28272675befb800eccc49b691', 
'3b7f30db8c6594c5ec677d3465d47735','4054aedd79682a798d862e431be27636', 
'4bee7a9cc7fd74a55e640ef6aca3864c','578e241dad54248261c341526563448b', 
'59283ec34b7faa9db1c0befa38e34ea2','64a0fdc8019b32a5768900c6c30a6e66', 
'65a767a4e7df8a06701c806f417c1de7','6719ab0291205b374cd50577f0a16ad7', 
'6bde8f55ddb7764138d4937dfaf85795'); 

Das gibt 21 „Reihen“, obwohl es 25 Zeilen zurückgeben sollte, eine für jede bar_id.

Um zu bestätigen, dass die Daten für alle 25 bar_id ist es, lief ich die folgende Abfrage, ein bar_id zu einer Zeit mit:

SELECT * FROM stagekeyspace.item_index WHERE foo_id IN 
('1947dccc791ace5eb40dd2f00d9d876f') AND bar_id IN ('5f715d9f4a1a97b8fb54996bca5b0d91'); 

Alle 25 Abfragen geben eine Zeile mit den richtigen Daten.

Gibt es irgendwelche Hinweise darauf, warum die erste Abfrage nicht alle Ergebnisse zurückgibt, sollte es?

Ich habe andere Abfragen im System, die eine SELECT .. WHERE x in ([LIST]) mit über 100 Elemente in der Liste verwenden und sie ohne Probleme ausgeführt werden. Außerdem ist jede Datenzeile weniger als 1 KB groß.

All dies läuft auf einem Ubuntu-Bild mit:

[cqlsh 3.1.6 | Cassandra 1.2.8 | CQL spec 3.0.0 | Thrift protocol 19.36.0] 

Edit: eine Spur Hinzufügen wie gewünscht. Bitte beachten Sie, dass einige der Spaltendaten geändert hat und die Ergebnisse sind jetzt auf 18 statt 25:

Tracing session: 4245fd80-a457-11e3-9933-19b599adc7ff 

activity            | timestamp | source  | source_elapsed 
------------------------------------------------------+--------------+--------------+---------------- 
            execute_cql3_query | 11:14:03,225 | 10.144.3.175 |    0 
Parsing SELECT count(*) FROM stagekeyspace.image_index WHERE domain_id 
IN ('1947dccc791ace5eb40dd2f00d9d876f') 
AND image_id IN ('64a8708d33b426315480b127a36663fd', 
.., '6bde8f55ddb7764138d4937dfaf85795') LIMIT 10000; | 11:14:03,225 | 10.144.3.175 |    47 
     Executing single-partition query on image_index | 11:14:03,226 | 10.144.3.175 |   733 
            Peparing statement | 11:14:03,225 | 10.144.3.175 |   172 
         Acquiring sstable references | 11:14:03,226 | 10.144.3.175 |   750 
          Merging memtable tombstones | 11:14:03,226 | 10.144.3.175 |   776 
         Key cache hit for sstable 76 | 11:14:03,226 | 10.144.3.175 |   945 
    Seeking to partition indexed section in data file | 11:14:03,226 | 10.144.3.175 |   959 
         Key cache hit for sstable 75 | 11:14:03,226 | 10.144.3.175 |   1061 
    Seeking to partition indexed section in data file | 11:14:03,226 | 10.144.3.175 |   1071 
         Key cache hit for sstable 74 | 11:14:03,226 | 10.144.3.175 |   1263 
    Seeking to partition indexed section in data file | 11:14:03,226 | 10.144.3.175 |   1277 
         Key cache hit for sstable 73 | 11:14:03,226 | 10.144.3.175 |   1421 
    Seeking to partition indexed section in data file | 11:14:03,226 | 10.144.3.175 |   1433 
      Merging data from memtables and 4 sstables | 11:14:03,226 | 10.144.3.175 |   1459 
        Read 18 live and 0 tombstoned cells | 11:14:03,230 | 10.144.3.175 |   5298 
            Request complete | 11:14:03,230 | 10.144.3.175 |   5845 

Answer 1

Cassandras ein bisschen faul tun vollständige Tabellenscans: ‚Allow FILTERING‘ lösen das Problem nicht anhängt? Zum Beispiel

SELECT * FROM stagekeyspace.item_index WHERE ... ALLOW FILTERING;