使用PrestoSQL查询MongoDB Atlas时抛出“Document does not contain key clusterTime”错误

这个问题我之前帮同行排查过，根源是PrestoSQL 334/338版本的MongoDB连接器使用的Java驱动和MongoDB Atlas的集群响应格式不兼容——旧驱动会强制要求响应中包含clusterTime字段，但Atlas的部分读取操作响应里并没有返回这个字段，直接触发了org.bson.BsonInvalidOperationException: Document does not contain key clusterTime错误。

先回顾下你的环境配置（来自你的描述）：

connector.name=mongodb
mongodb.seeds=XXX-shard-00-00-6owtm.gcp.mongodb.net:27017,XXX-shard-00-01-6owtm.gcp.mongodb.net:27017,XXX-shard-00-02-6owtm.gcp.mongodb.net:27017
mongodb.credentials=xxx:xxx@reader
mongodb.ssl.enabled=true
mongodb.write-concern=MAJORITY
mongodb.required-replica-set=XXX-shard-0

下面是几个可行的解决方案，按优先级排序：

1. 升级PrestoSQL到更高版本（推荐） #

PrestoSQL 334/338属于较早的版本，后续发布的版本（比如340及以上）已经修复了MongoDB驱动兼容Atlas的问题，官方更新了驱动版本并调整了clusterTime的处理逻辑，不再强制要求该字段存在。

升级步骤：

• 下载对应版本的PrestoSQL安装包
• 备份现有配置文件（etc目录下的所有文件）
• 替换安装目录，恢复备份的配置
• 重启Presto集群

升级后执行简单查询验证：

SELECT * FROM mongo.<你的schema>.<你的集合> LIMIT 1;

2. 添加禁用clusterTime检查的配置参数（如果版本支持） #

部分Presto MongoDB连接器版本支持通过配置参数禁用clusterTime的强制检查，尝试在你的MongoDB目录配置文件中添加：

mongodb.use-cluster-time=false

添加后重启Presto服务，再执行查询测试。注意：这个参数并非所有旧版本都支持，如果添加后启动报错，说明你的版本不支持该参数，需要尝试其他方案。

3. 手动替换MongoDB Java驱动包 #

如果暂时无法升级Presto，可以手动替换连接器中的MongoDB驱动包为兼容Atlas的版本（推荐3.12.x及以上版本，该版本对clusterTime的处理更灵活，缺失时不会抛出异常）：

步骤：

1. 停止Presto服务
2. 进入Presto的MongoDB插件目录，通常路径为：

   cd $PRESTO_HOME/plugin/mongodb
   

3. 移除旧的MongoDB驱动jar包（文件名类似mongo-java-driver-*.jar）
4. 下载MongoDB Java驱动3.12.x版本的jar包，放到该目录
5. 重启Presto服务

4. 验证用户权限（辅助排查） #

虽然报错根源大概率是驱动兼容，但也可以确认下你的MongoDB用户reader是否拥有足够的读取权限：

• 登录MongoDB Atlas控制台，检查该用户对目标数据库和集合的read权限是否配置正确
• 用mongo客户端连接Atlas，执行相同的查询，确认能正常返回数据，排除权限问题

验证完成后再测试Presto的查询。

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