spark-cassandra-cnx-faildemo:Spark-Cassandra 连接器故障演示

spark-cassandra-cnx-faildemo 我创建这个是为了演示将大量数据集保存到表时在 spark-cassandra 连接器中发生的不可恢复的异常 准备 请注意，此错误仅在远程cassandra 集群上可见，因此您需要启动一个。 我建议在此处使用 DSE AMI： : 在 cql 文件夹中有一个名为 schema.cql 的文件，确保在您的 cassandra 集群上执行它以设置应用程序的架构 在您的 cassandra 集群上运行这些语句以准备它接受您的数据 更新 src/main/scala/FakeDataStreamer.scala 确保第 20 行显示了 cassandra 集群上头节点的 IP 地址 config.set("spark.cassandra.connection.host", yourClusterHost) 正确设置主机后，在 rep