mujingjing

Results 2 comments of mujingjing

I wish to run the following SQL: **SELECT name FROM (SELECT * FROM people) T GROUP BY name** and I getting same exception as: **java.lang.ClassCastException: com.alibaba.druid.sql.ast.statement.SQLSubqueryTableSource cannot be cast to...

**出现原因**:由于Starrocks设定了查询超时时间,DataX数据同步使用流式数据读取,导致数据读取超过了数据库指定的查询超时时间,数据读取被中断,DataX没有报错,出现了Speed一直为0的情况。 **处理方法**: 1. 可以暂时将数据库的query_timout参数调大,保证数据同步时间不会超过该值。 ```sql set global query_timeout=3000; ``` 2. 在当前SQL语句中设置query_timeout的值,详见:[https://docs.starrocks.com/zh-cn/latest/reference/System_variable](https://docs.starrocks.com/zh-cn/latest/reference/System_variable) ```sql SELECT /*+ SET_VAR(query_timeout = 1) */ name FROM people ORDER BY name; ``` **具体说明:** 1. DataX的数据同步,采用的是使用java.sql.Statement从数据库拉取数据,并且将fetchSize设置成了Integer.MIN_VALUE, 该方式使用流数据接受方式,每次只从服务器接受部分数据,直到数据处理完毕。 源码如下:...