tispark 示例程序中需要 pd server 的地址。我的 tidb 集群是用 k8s 部署的。 spark 集群是用 cm 部署的。
我试了下直接转发这个服务,也还是不行。相关代码如下:
val sparkConf = new SparkConf()
.setIfMissing("spark.tispark.write.allow_spark_sql", "true")
.setIfMissing("spark.master", "local[4]")
.setIfMissing("spark.app.name", getClass.getName)
.setIfMissing("spark.sql.extensions", "org.apache.spark.sql.TiExtensions")
.setIfMissing("spark.tispark.tidb.addr", "172.16.1.130")
.setIfMissing("spark.tispark.tidb.password", "example")
.setIfMissing("spark.tispark.tidb.port", "30438")
.setIfMissing("spark.tispark.tidb.user", "root")
.setIfMissing("spark.tispark.pd.addresses", "172.16.1.130:3379")
报错:
Caused by: java.net.UnknownHostException: tidb-cluster-001-pd-1.tidb-cluster-001-pd-peer.tidb-system.svc
完整的报错信息:Ubuntu Pastebin