ob库报错Timeout的坑

桃扇骨 2024-02-05 12:15 121阅读 0赞

一、问题描述

最近数据库从mysql迁移到了ocean base；

之前好多kettle定时任务用来数据加工，结果迁移到ob总是报错Timeout：

  1. org.pentaho.di.core.exception.KettleDatabaseException:
  2. Couldn't get row from result set
  3. Timeout
  4.         at org.pentaho.di.core.database.Database.getRow(Database.java:2546)
  5.         at org.pentaho.di.core.database.Database.getRow(Database.java:2516)
  6.         at org.pentaho.di.trans.steps.tableinput.TableInput.processRow(TableInput.java:148)
  7.         at org.pentaho.di.trans.step.RunThread.run(RunThread.java:62)
  8.         at java.lang.Thread.run(Thread.java:748)
  9. Caused by: java.sql.SQLException: Timeout
  10.         at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1055)
  11.         at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:956)
  12.         at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3558)
  13.         at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3490)
  14.         at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:919)
  15.         at com.mysql.jdbc.MysqlIO.nextRow(MysqlIO.java:1416)
  16.         at com.mysql.jdbc.RowDataDynamic.nextRecord(RowDataDynamic.java:416)
  17.         at com.mysql.jdbc.RowDataDynamic.next(RowDataDynamic.java:395)
  18.         at com.mysql.jdbc.ResultSetImpl.next(ResultSetImpl.java:7104)
  19.         at org.pentaho.di.core.database.Database.getRow(Database.java:2534)
  20.         ... 4 more

不知道是ob的哪个设置与mysql不一样，导致的。

二、解决方法

1.在select语句中使用/*+READ_CONSISTENCY(WEAK), QUERY_TIMEOUT(100000000)*/
样例如下：

  1. select 
  2. /*+READ_CONSISTENCY(WEAK), QUERY_TIMEOUT(100000000)*/
  3. id,name from mytable

就放在select的后面就可以了，这个可以解决一部分Timeout报错。

2.发现当kettle的任务链太长时，跑到某一步也会报错Timeout；

解决方法就是把kettle任务链拆分，每个短一些，分不同时间执行；

任务链短的话就不会Timeout了，但是不能保证执行顺序，需要每个任务的间隔时间长一些，确保可以执行完毕。

发表评论

表情：
评论列表 （有 0 条评论，121人围观）

还没有评论，来说两句吧...

相关阅读