Elasticsearch Scala API从5.6升级至7.1后触发ClassCastException问题求助

看起来你遇到的问题核心在于Elasticsearch 7.x客户端API与5.x版本的聚合响应解析逻辑不兼容，虽然Kibana里JSON响应看起来正常，但Scala代码里的旧解析逻辑无法适配新版本客户端的强类型聚合对象结构。

问题根源 #

在ES 5.6中，客户端可能允许你直接从聚合结果的Map结构中提取数值（比如doc_count），但升级到7.1后，官方客户端改用了强类型的聚合对象（如Nested、Terms类）来封装聚合结果。如果你的esToJsonOrganizationPeopleFilters方法还是沿用旧的Map取值+强制类型转换的方式，就会出现scala.collection.immutable.Map$Map2 cannot be cast to java.lang.Integer的错误——因为现在聚合字段的封装结构已经不是直接的Integer了。

解决方案 #

1. 确保客户端版本与ES 7.1完全匹配 #

首先确认你使用的Scala ES客户端（比如elastic4s或官方high-level client）版本是7.1.x系列，版本不匹配会导致大量API兼容问题。

2. 修改聚合响应解析逻辑 #

改用ES 7.x客户端提供的强类型聚合类来解析结果，而不是直接操作原始Map。以下是修正后的esToJsonOrganizationPeopleFilters示例代码：

import org.elasticsearch.action.search.SearchResponse
import org.elasticsearch.search.aggregations.Aggregations
import org.elasticsearch.search.aggregations.bucket.nested.Nested
import org.elasticsearch.search.aggregations.bucket.terms.Terms
import scala.collection.JavaConverters._

def esToJsonOrganizationPeopleFilters(response: SearchResponse): IO[PostFilters] = {
  // 获取顶层聚合集合
  val aggregations: Aggregations = response.getAggregations
  
  // 提取nested聚合结果
  val peopleNestedAgg: Nested = aggregations.get("people")
  // 提取嵌套内的terms聚合
  val positionTypeTerms: Terms = peopleNestedAgg.getAggregations.get("positiontype")
  
  // 遍历terms的bucket，转换为业务需要的结构
  val positionFilters = positionTypeTerms.getBuckets.asScala.map { bucket =>
    // 正确获取bucket的key和文档计数
    bucket.getKeyAsString -> bucket.getDocCount.toInt
  }.toMap
  
  // 根据你的业务构造PostFilters对象，这里请替换为实际的构造逻辑
  IO.pure(PostFilters(positionFilters))
}

3. 关键注意点 #

• 避免直接从聚合结果中强制转换Map值：7.x客户端的聚合对象都是强类型的，必须通过对应的getter方法（如getDocCount()、getKeyAsString()）获取字段值。
• getDocCount()返回的是Long类型，转Int时要注意数值范围，如果你的文档计数可能超过Int上限，建议业务代码改用Long类型存储。

验证 #

修改后重新执行代码，应该能正常解析聚合结果，不会再触发ClassCastException。如果还有问题，可以检查PostFilters类的构造逻辑，确保传入的参数类型与解析结果匹配。

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