文件名称：spark-cassandra-cnx-faildemo:Spark-Cassandra 连接器故障演示
文件大小：8KB
文件格式：ZIP
更新时间：2024-06-24 11:09:01
Scala
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
【文件预览】：
spark-cassandra-cnx-faildemo-master
----sparkdefaults.conf(67B)
----src()
--------main()
----build.sbt(1KB)
----errlog.log(162B)
----.gitignore(55B)
----launch.sh(65B)
----project()
--------plugins.sbt(82B)
--------build.properties(20B)
----README.md(2KB)
----cql()
--------schema.cql(434B)