spark.cassandra.connection.connections_per_executor_max 不是有效的 spark cassandra

Question

使用 cassandra 连接器 2.5.2 时出现以下错误：

spark.cassandra.connection.connections_per_executor_max 不是有效的 spark cassandra 连接器变量。

在 cassandra 连接器 2.4 中，此参数可以正常工作。

cassandra 连接器 2.5.2 中是否有任何等效选项？

谢谢！

我的代码中的示例：

val sparkSession = SparkSession
            .builder()
            .config("spark.cassandra.connection.connections_per_executor_max", 160)

Answer 1

我可以在v2.5.2 documentation 中看到spark.cassandra.connection.localConnectionsPerExecutor 和spark.cassandra.connection.remoteConnectionsPerExecutor 配置。