Execute_concurrent Кассандры не работает должным образом
Я согласен с ответом от zacherates.
Но вы можете сделать вызов intern () в ваших нелиберальных строках.
Из примера zacherates:
// ... but they are not the same object
new String("test") == "test" ==> false
Если вы ставите нелитеральное равенство строки, это правда
new String("test").intern() == "test" ==> true
1 ответ
Вы не устанавливаете параметр concurrency для execute_concurrent, и по умолчанию он использует 100.
Из документации :
Параметр параллелизма контролирует, сколько операторов будет выполняться одновременно. Когда для
Cluster.protocol_versionустановлено значение 1 или 2 , рекомендуется, чтобы это значение было ниже 100-кратного числа подключений к ядру на хост, умноженного на количество подключенных хостов (см. [113 ]). Если это количество превышено, поток цикла событий может попытаться заблокировать создание нового соединения, что существенно повлияет на пропускную способность. Если protocol_version равен 3 или выше, вы можете смело экспериментировать с более высокими уровнями параллелизма.