遇到这种跨缓存模式关联查不到表的问题确实挺闹心的，我之前在做Ignite多缓存关联的时候也踩过类似的坑，结合你的代码和场景，咱们来一步步分析问题根源和解决办法：

先捋清楚核心问题可能出在哪 #

从你的描述来看，Company表已经成功加载到REPLICATED缓存，但从PARTITIONED的Employee缓存上下文执行关联查询时找不到它，大概率是查询上下文的表元数据范围限制或者集群元数据同步的问题：

1. 当你通过cache.query(query)提交查询时，Ignite默认会以当前缓存的SQL Schema为上下文，只扫描该缓存所在节点上已注册的同Schema表；但REPLICATED缓存的表元数据可能还没同步到当前查询所在的PARTITIONED缓存节点，或者在当前缓存的查询上下文里没有被正确识别。
2. 虽然你已经开启了setDistributedJoins(true)，但如果查询没有明确指定Schema，或者两个缓存的Schema配置有隐性不一致（比如大小写、拼写差池），也会导致表找不到。

针对性的解决办法，按优先级排序 #

1. 改用Ignite全局SQL接口执行跨缓存查询

这是最直接的解决方式：不要通过某个具体缓存的query()方法提交查询，而是用Ignite实例的全局SQL接口ignite.sql().query()，这样查询会在集群全局上下文执行，扫描所有缓存中注册在目标Schema下的表，不受单个缓存的模式限制。

修改你的查询方法：

QueryCursor<List<?>> getQueryCursor(String sql, Ignite ignite) {
    SqlFieldsQuery query = new SqlFieldsQuery(sql);
    query.setDistributedJoins(true);
    query.setLazy(true);
    query.setTimeout(0, TimeUnit.MILLISECONDS);
    // 改用全局SQL接口执行
    return ignite.sql().query(query);
}

2. 查询时明确指定SQL Schema

如果不想改查询接口，那就在SQL语句里显式带上Schema名，避免Ignite在当前缓存上下文的Schema里找表：

SELECT e.*, c.* FROM your_schema_name.employee e JOIN your_schema_name.company c ON e.id = c.employee_id

这里要确保your_schema_name和你两个缓存配置里setSqlSchema(schemaName)的schemaName完全一致（包括大小写，Ignite的SQL Schema默认是大小写敏感的）。

3. 确认REPLICATED缓存的表元数据已完全同步到集群

有时候REPLICATED缓存启动、数据加载完成后，表元数据还需要一点时间同步到所有Server节点（尤其是你有5个Server节点的场景）。你可以在执行查询前加个校验逻辑，等Company表的元数据在集群中完全注册后再执行查询：

// 校验表是否存在的工具方法
private boolean waitForTableRegistered(Ignite ignite, String schemaName, String tableName, long timeoutMs) {
    long start = System.currentTimeMillis();
    while (System.currentTimeMillis() - start < timeoutMs) {
        try {
            // 尝试查询表的元数据
            ignite.sql().query(new SqlFieldsQuery(String.format("SELECT 1 FROM %s.%s LIMIT 1", schemaName, tableName)));
            return true;
        } catch (Exception e) {
            // 表还没注册，继续等待
            try {
                Thread.sleep(1000);
            } catch (InterruptedException ie) {
                Thread.currentThread().interrupt();
                return false;
            }
        }
    }
    return false;
}

在执行关联查询前调用这个方法，确认表已注册：

if (waitForTableRegistered(ignite, schemaName, "company", 30000)) {
    // 执行关联查询
    QueryCursor<List<?>> cursor = getQueryCursor(sql, ignite);
    // 后续逻辑
} else {
    log.error("Company表在30秒内未完成注册，无法执行查询");
}

4. 检查QueryEntity和缓存配置的一致性

再核对下你的createQueryEntity方法，确保：

• Company表对应的pojoTableName和查询里的company完全一致（注意大小写，比如Postgres的表名如果是小写，Ignite的QueryEntity也要用小写，或者查询时统一大小写）；
• 两个缓存的setSqlSchema(schemaName)设置的是同一个Schema，没有拼写错误；
• REPLICATED缓存的setQueryEntities和setIndexedTypes配置正确，实体类和表的映射关系没有问题。

调试小技巧 #

如果还是找不到问题，可以打开Ignite的SQL DEBUG日志，在日志配置里把org.apache.ignite.internal.processors.query的日志级别设为DEBUG，这样能看到Ignite解析SQL时的表查找过程，比如它在哪个Schema下找表、有没有加载到Company表的元数据，帮你快速定位问题。

内容来源于stack exchange