我正在试验一个家庭集群,但我想在 IntelliJ 中调试它。
SnappyData 文档说,在本地模式下,我可以在我的驾驶程序中创建一个 SnappySession,根据我的 Spark 经验,我可以在连接到 Spark 集群时在本地运行它。这对调试非常有用。
val spark: SparkSession = SparkSession
.builder
.appName("SparkApp")
.master("local[*]")
.getOrCreate
val snappy = new SnappySession(spark.sparkContext)
但是当我开始处理更多数据时,我仍然希望能够进行调试,同时还要测试我的集群的性能。为此,我希望能够在以Embedded Mode连接到集群时做同样的事情。鉴于 Lead 托管 Spark 驱动程序,或者我正在寻找的可能是在服务器上,当我运行嵌入式模式集群时,是否有可以使用相同代码连接的系统?如何找到该系统的地址和端口?(我没有从 Snappy-Start-All.sh 获得太多命令行反馈。)