Spark/Scala读取Oracle数据时最后一批记录请求挂起求助

• 数据库端会话阻塞
  登录Oracle数据库，查询v$session视图定位对应连接的状态与等待事件：

  SELECT sid, serial#, status, wait_class, event FROM v$session WHERE username = '你的用户名';
  

  若会话状态为WAITING，重点关注等待事件：如果是enqueue类事件，说明存在锁冲突，需排查其他会话是否锁住了目标表/行；如果是IO类事件（如db file sequential read），则可能是存储性能瓶颈导致最后一批数据读取受阻。

• 驱动与Oracle版本不兼容
  确认驱动版本与Oracle服务器版本的匹配性：

  • ojdbc8适配Oracle 12c/18c
  • ojdbc11适配Oracle 19c/21c/23c
    若服务器与驱动版本不匹配（比如用ojdbc11连接11g服务器），极易引发协议交互异常。建议更换与服务器版本完全匹配的驱动重试。

• 特殊数据类型读取阻塞
  如果查询包含CLOB、BLOB等大字段，驱动在解析最后一批数据中的大字段时可能出现bug或IO阻塞。尝试修改查询，去掉大字段列，或用DBMS_LOB.SUBSTR截断大字段内容，若问题消失，说明是大字段处理问题——可升级驱动版本，或调整大字段读取的相关配置。

• Fetch Size边界触发的协议异常
  尝试将fetch size设为大于总记录数的值（比如查询499条时设为1000），让驱动一次性读取所有数据。若此方法可行，说明驱动在处理剩余行数不足fetch size的批次时存在bug，可尝试升级驱动，或在代码中动态设置fetch size为总记录数+1来规避。

• 数据库网络配置问题
  检查数据库端sqlnet.ora的关键参数：

  • RECV_TIMEOUT/SEND_TIMEOUT：是否因设置过短导致连接提前断开，或过长导致无响应无法及时检测
  • SDU（会话数据单元）：若设置过大可能引发数据包丢失，尝试调整为默认值8192
    同时排查客户端网络环境，比如防火墙是否拦截特定大小的数据包，或链路是否存在丢包情况。

• 查询执行计划异常
  生成并分析查询的执行计划：

  EXPLAIN PLAN FOR 你的查询语句;
  SELECT * FROM TABLE(DBMS_XPLAN.DISPLAY);
  

  若执行计划中出现全表扫描、索引失效或分区未命中的情况，会导致最后一批数据读取耗时过长。可尝试添加查询提示（如/*+ INDEX(表名 索引名) */）强制使用索引，或更新表统计信息：

  ANALYZE TABLE 表名 COMPUTE STATISTICS;
  

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