Обычно я могу подключиться к удаленному кластеру в режиме клиента следующим образом:
val conf = new SparkConf()
conf.setAppName("Spark Yarn Test")
conf.set("spark.driver.host", "192.168.99.1")
conf.setMaster("spark://192.168.99.100:7077")
val spark = SparkSession.builder.config(conf).getOrCreate()
Но как я могу подключиться к искровому кластеру в IBM Analytics Engine в IBM Cloud? Я попытался использовать режим пряжи, как показано ниже, но, к сожалению, я не могу найти конечную точку для менеджера ресурсов пряжи.
val conf = new SparkConf()
conf.setAppName("Spark Yarn Test")
conf.set("spark.hadoop.yarn.resourcemanager.address", "<resource-manager-endpoint>")
conf.set("spark.driver.host", "192.168.99.1")
conf.setMaster("yarn-client")
val spark = SparkSession.builder.config(conf).getOrCreate()
Пожалуйста, помогите в этом.