为何未触发预期同步API检测异常，却抛出Cassandra PT2S超时？

为什么未触发Detected a synchronous API...异常 #

DataStax Java Driver的该异常仅在Driver异步上下文（如Netty IO线程）中调用Driver自身的同步API时触发（例如在executeAsync回调里调用session.execute()这类同步执行方法）。你的代码中仅调用了Thread.sleep()，属于通用阻塞操作，并不涉及Driver同步API的调用，因此不会触发该检测逻辑。

为什么出现Cassandra timeout after PT2S异常 #

问题根源在于阻塞了Driver的核心IO线程：

• cqlSession.executeAsync()的回调链（包括thenApply(AsyncResultSet::wasApplied)）默认运行在Driver的Netty IO线程池内。
• 后续cf.thenApply()中加入的Thread.sleep(60000)会复用同一IO线程，导致该线程被长时间阻塞。
• Driver的IO线程池容量有限，一旦线程被占用阻塞，Netty无法及时处理Cassandra返回的响应。Cassandra端在默认2秒超时时间内未收到客户端的有效处理反馈，因此抛出超时异常。
• 移除Thread.sleep()后，IO线程可正常处理响应，因此无异常。

优化建议 #

如果需要在异步回调中执行阻塞操作，应使用thenApplyAsync()并指定自定义线程池，避免占用Driver的核心IO线程：

ExecutorService customPool = Executors.newFixedThreadPool(4);
cf.thenApplyAsync(s -> {
    try {
        Thread.sleep(60000);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
    return null;
}, customPool)
.get(10, TimeUnit.SECONDS);

内容的提问来源于stack exchange，提问作者user1234SI.