我正在使用用于java的datastax驱动程序：

@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 ).
同步插入工作正常，但速度太慢了。
我想用datastaxjava驱动Map器解决这个问题，基于注解，尽可能简单。
驱动程序版本：4.9.0