Apache Ignite多节点下因数据未共置导致Join查询结果错误

首先咱们拆解下你遇到的两个核心问题：多节点下Join结果异常，以及添加亲和键配置后触发的BinaryObjectException，一步步来解决。

一、错误原因分析 #

1. 多节点Join结果错误 #

你初始配置里缓存是REPLICATED模式（每个节点存全量数据），理论上Join不会有问题，但你提到“数据未共置”，推测你后来把缓存模式改成了PARTITIONED（分区模式）。这种模式下，如果Ratings和Movies数据没有基于movieId共置到同一节点，跨节点Join就会因为数据分布逻辑问题返回错误结果。

2. BinaryObjectException异常 #

这个异常Binary type has different affinity key fields的本质是：集群内不同节点对RatingsKey类的二进制元数据定义不一致——有的节点配置了亲和键movie_id，有的节点没配置，或者字段名匹配错误。具体来看有两个点：

• 你只在Spring Boot节点的配置里加了cacheKeyConfiguration，但独立Ignite节点的配置（MovieRatingsCluster）里没有这个配置，导致节点间元数据冲突；
• XML里affinityKeyFieldName写的是数据库列名movie_id，但Java类RatingsKey里的字段是驼峰命名的movieId，Ignite找不到对应字段，进而引发元数据异常。

二、分步解决方案 #

1. 统一所有节点的Ignite配置 #

多节点集群要求所有节点的配置完全一致，你需要把cacheKeyConfiguration添加到所有节点的配置文件中，包括Ignite安装目录下的那个配置：

<bean class="org.apache.ignite.configuration.IgniteConfiguration">
    <!-- 保留原有其他配置 -->
    <property name="cacheKeyConfiguration">
        <list>
            <bean class="org.apache.ignite.cache.CacheKeyConfiguration">
                <property name="typeName" value="com.learnwithmanoj.ignite.model.RatingsKey" />
                <!-- 注意：这里要写Java类的字段名，不是数据库列名 -->
                <property name="affinityKeyFieldName" value="movieId" />
            </bean>
        </list>
    </property>
</bean>

2. 修改缓存模式为PARTITIONED并完成亲和键配置 #

要实现数据共置，需要把缓存模式从REPLICATED改为PARTITIONED，同时确保：

• MoviesCache的键是movieId（天然基于movieId分区）；
• RatingsCache的亲和键设为movieId，这样同一movieId的评分数据会和对应的电影数据存在同一节点。

修改两个缓存的cacheMode属性：

<property name="cacheMode" value="PARTITIONED"/>

3. 检查实体类注解（避免配置冲突） #

如果你的RatingsKey类用了Ignite的注解（比如@AffinityKeyMapped），请确保注解和XML配置二选一，不要混合使用。例如如果类里已经有：

public class RatingsKey {
    private int userId;
    @AffinityKeyMapped
    private int movieId;
    // Getters & Setters
}

那你可以去掉XML中的cacheKeyConfiguration，统一用注解配置亲和键。

4. 清理元数据并重启所有节点 #

如果之前启动过节点，Ignite可能缓存了旧的二进制元数据，需要：

• 关闭所有Ignite节点；
• 删除每个节点的Ignite工作目录（默认路径是{IGNITE_HOME}/work）；
• 重新启动所有节点，确保新配置完全生效。

三、验证查询 #

完成以上配置后，再次执行你的Join查询：

select r.movie_id, m.movie_name, count(r.rating) as count from "RatingsCache".ratings r inner join "MoviesCache".movies m where r.movie_id = m.movie_id group by r.movie_id order by count desc limit 5;

现在同一movieId的Ratings和Movies数据会共置在同一个节点，Join查询就能返回正确结果了。

内容的提问来源于stack exchange，提问作者Manoj - GT