Scala/Spark/H2O示例程序编译通过，H2OContext.getOrCreate调用报错求助

首先，我一眼就看到了两个关键问题，先帮你逐个解决：

1. 直接触发异常的变量名错误 #

你调用H2OContext.getOrCreate(sess)时，代码里根本没有定义名为sess的变量！你创建的SparkSession实例明明叫spark，所以这里必须改成H2OContext.getOrCreate(spark)——这是最直接的语法错误，也是触发异常的核心原因之一。

2. Spark上下文重复初始化的潜在冲突 #

你同时手动创建了SparkContext和SparkSession，这在Spark 2.x及以后的版本里完全没必要，甚至会导致上下文冲突。SparkSession已经封装了SparkContext，只需要通过SparkSession.builder初始化即可，单独创建SparkContext反而会干扰H2O的上下文绑定。

修正后的完整代码 #

我帮你调整了代码结构，解决了上述问题，同时补充了资源关闭的最佳实践：

object App1 extends App {
  // 统一通过SparkSession初始化上下文，避免重复创建
  val spark = SparkSession.builder
    .master("local[1]") // 和你原配置保持一致，用单线程本地模式
    .appName("AppTest")
    .config("spark.executor.memory", "1g")
    .getOrCreate()
  
  import spark.implicits._
  
  // 使用正确的SparkSession实例初始化H2OContext
  val h2oContext = H2OContext.getOrCreate(spark)
  
  // 在这里编写你的业务逻辑代码...
  
  // 程序结束时记得关闭资源
  h2oContext.stop()
  spark.stop()
}

额外的兼容性注意事项 #

如果修正后还是抛出异常，大概率是版本不匹配的问题：

• Spark与Sparkling-Water版本必须严格对应：H2O的Spark集成库sparkling-water的版本要和你的Spark版本完全一致，比如Spark 3.3.x对应sparkling-water 3.3.x系列，版本不兼容会直接导致上下文初始化失败。
• JDK版本限制：H2O对JDK版本有要求，一般推荐用JDK 8或11，避免使用JDK 17+（除非你用的是最新版H2O）。
• 本地模式端口冲突：如果本地已经有其他Spark或H2O实例在运行，先关闭它们再测试，避免端口占用导致的初始化异常。

内容的提问来源于stack exchange，提问作者ps0604