Блог

Я использую драйвер datastax для Java:

 @Dao
public interface MyDao {
    @Insert
    CompletableFuture<Void> save(MyEntity entity);
    ...
}

public class MyDaoTests {
    
    @Test
    public void myTest() {
    ...
    List<CompletableFuture<Void>> futureList = myEntityList.parallelStream()
             .map((myEntity) -> meterDataMapper.myDao().save(myEntity))
             .collect(Collectors.toList());
    CompletableFuture.allOf(futureList.toArray(CompletableFuture[]::new)).join();
    ...
   }
}
 

Когда я выполняю тест, я получаю эту ошибку:
java.util.concurrent.CompletionException: com.datastax.oss.driver.api.core.NoNodeAvailableException: No node was available to execute the query

Есть ли способ настроить драйвер / сеанс на ожидание доступных узлов?

Дополнительная информация:

• Размер моего теста составляет около 2500000 объектов ( myEntityList ).
• Синхронные вставки работают нормально, но они слишком медленные.
• Я хочу решить эту проблему с помощью картографа datastax-java-driver, основанного на аннотациях, как можно проще.
• Версия драйвера: 4.9.0

NoNodeAvailableException Возвращается, когда драйвер пометил все узлы как отключенные или не отвечающие, или когда точки контакта недействительны (в вашем случае это маловероятно).

Это не тот случай, когда драйвер должен ждать, пока узлы вернутся в оперативный режим. Поскольку драйвер считает, что все узлы недоступны, он даже не пытается подключиться к каким-либо узлам.

Просмотрите журналы на узлах, чтобы узнать, почему они не отвечают. Если вы видите длительные паузы GC и / или пропущенные чтения / мутации, это признак того, что узлы перегружены. Если вы выполняете нагрузочный тест, рассмотрите возможность уменьшения пропускной способности, чтобы не перегружать ваш кластер. Приветствия!