Cassandra插入失敗

Question

我們遇到了在cassandra表中寫入數據的問題。

流程如下..我們使用一些主鍵從XXX中刪除所有記錄。 然後在循環中插入新的。

execute("DELETE FROM XXX WHERE key = {SOME_UUID}"); 

for(int i = 0; i < 5; ++i) { 
    execute("INSERT INTO XXX (key, field1, field2) VALUES ({SOME UUID},'field1','field2')"; 
} 

結果：有時不是所有的行都插入表中。查詢表後，我們看到並未插入所有行。

的環境，我們有：

我們使用DataStax企業版（4.5.2）。卡桑德拉2.0.10。 數據中心有4個節點，我們的密鑰空間設置爲replication_factor設置爲3. 查詢CONSISTENCY_LEVEL設置爲LOCAL_QUORUM。

java驅動程序是數據stax企業2.1.1

在此先感謝。 任何幫助，將不勝感激。

Answer 1

我在你的例子中假設SOME_UUID對於刪除和插入是相同的。

這可能是刪除（邏輯刪除）和傳播到所有節點的新插入（根據您的複製因子）之間的競爭條件。如果刪除和插入標記有相同的時間戳，則刪除將獲勝。您可能會遇到在某些節點上刪除成功的情況，而在其他節點上，插入成功。

您可以嘗試將RF降至1，如@ BryceAtNetwork23建議的那樣。

另一個測試是在刪除和插入for循環之間的示例代碼中插入一個延遲（如500ms）。這會給插入前的刪除傳播時間。

根據您的數據模型，這裏最好的解決方案可能是避免刪除。