从 c#datastax 驱动程序关闭 cassandra 集群时出错

Question

我正在使用 Datastax C# 驱动程序从我的 C# 应用程序连接到 Cassandra 节点。我的代码工作正常，我能够检索所有数据并处理它们。但是，当我在获取记录后尝试关闭集群时，它给了我上述错误。下面是我的 Connect 方法代码。

public ISession Connect()
{
    cluster = Cluster.Builder().AddContactPoint(NodeIp).Build();       //node ip
    ISession session = cluster.Connect(ClusterName);                   //database name
    return session;
}

任何帮助将不胜感激。

Answer 1

关闭集群时，驱动程序使用 STAThreads 不支持的WaitHandle.WaitAll()。

关闭时驱动应该支持STAThreads，我创建了ticket for it。

与此同时，作为一种解决方法，您可以开始一个新任务并等待它。

Task.Factory.StartNew(() => cluster.Shutdown()).Wait();

---

更新

此错误已在最新版本中修复。