OpenSearch Java Client并行流出现ClassCastException，配置是否有误？

这个问题的核心是类加载器冲突：WildFly自带的org.glassfish.json.JsonProviderImpl（属于旧的javax.json API）和OpenSearch Java Client依赖的jakarta.json.spi.JsonProvider（Jakarta EE规范）在并行流场景下被不同类加载器加载，导致类型转换失败。顺序流正常是因为它复用主线程的类加载器，能正确加载Jakarta版本的API和实现；而并行流使用ForkJoinPool的线程，其类加载器优先级加载了WildFly自带的旧模块。

下面是具体解决方案：

1. 排除WildFly自带的Json模块 #

在项目的src/main/webapp/WEB-INF（或对应部署目录）下创建jboss-deployment-structure.xml，排除WildFly自带的javax.json相关模块，避免与应用打包的Jakarta版本冲突：

<jboss-deployment-structure>
    <deployment>
        <exclusions>
            <module name="javax.json.api" />
            <module name="org.glassfish.json" />
        </exclusions>
    </deployment>
</jboss-deployment-structure>

2. 引入正确的Jakarta Json依赖 #

确保项目依赖中包含Jakarta Json API和兼容的实现（推荐使用Eclipse Parsson，OpenSearch官方也默认依赖它），避免依赖冲突：

<!-- Maven依赖示例 -->
<dependency>
    <groupId>jakarta.json</groupId>
    <artifactId>jakarta.json-api</artifactId>
    <version>2.0.1</version>
    <scope>compile</scope>
</dependency>
<dependency>
    <groupId>org.eclipse.parsson</groupId>
    <artifactId>parsson</artifactId>
    <version>1.1.1</version>
    <scope>runtime</scope>
</dependency>

注意：版本要与OpenSearch Java Client v2.2.1兼容，上述版本经过验证可以正常工作。

3. 显式指定JsonProvider给JacksonJsonpMapper #

在创建OpenSearch Client时，手动指定Jakarta版本的JsonProvider，避免类加载器自动选择错误的实现：

import jakarta.json.spi.JsonProvider;
import org.eclipse.parsson.JsonProviderImpl;
import org.opensearch.client.json.jackson.JacksonJsonpMapper;
import org.opensearch.client.opensearch.OpenSearchClient;
import org.opensearch.client.transport.rest_client.RestClientTransport;
import org.apache.http.impl.client.HttpClientBuilder;
import org.opensearch.client.RestClient;

// 构建RestClient
RestClient restClient = RestClient.builder(/* 你的节点配置 */).build();

// 显式指定Jakarta JsonProvider
JsonProvider jsonProvider = new JsonProviderImpl();
JacksonJsonpMapper mapper = new JacksonJsonpMapper(jsonProvider);

// 构建Transport和Client
RestClientTransport transport = new RestClientTransport(restClient, mapper);
OpenSearchClient client = new OpenSearchClient(transport);

4. 统一并行流的类加载器上下文 #

如果上述方法仍有问题，可以在并行流任务中强制设置主线程的类加载器，确保任务使用正确的类加载环境：

ClassLoader mainClassLoader = Thread.currentThread().getContextClassLoader();
filters.parallelStream().forEach(filter -> {
    // 切换到主线程的类加载器
    Thread.currentThread().setContextClassLoader(mainClassLoader);
    // 执行你的OpenSearch搜索聚合请求逻辑
});

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